io.netty.util.concurrent.Future#syncUninterruptibly ( )源码实例Demo

下面列出了io.netty.util.concurrent.Future#syncUninterruptibly ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： netty-4.1.22 文件： Http2ConnectionRoundtripTest.java

@After
public void teardown() throws Exception {
    if (clientChannel != null) {
        clientChannel.close().syncUninterruptibly();
        clientChannel = null;
    }
    if (serverChannel != null) {
        serverChannel.close().syncUninterruptibly();
        serverChannel = null;
    }
    final Channel serverConnectedChannel = this.serverConnectedChannel;
    if (serverConnectedChannel != null) {
        serverConnectedChannel.close().syncUninterruptibly();
        this.serverConnectedChannel = null;
    }
    Future<?> serverGroup = sb.config().group().shutdownGracefully(0, 5, SECONDS);
    Future<?> serverChildGroup = sb.config().childGroup().shutdownGracefully(0, 5, SECONDS);
    Future<?> clientGroup = cb.config().group().shutdownGracefully(0, 5, SECONDS);
    serverGroup.syncUninterruptibly();
    serverChildGroup.syncUninterruptibly();
    clientGroup.syncUninterruptibly();
}

源代码2 项目： netty-4.1.22 文件： InboundHttp2ToHttpAdapterTest.java

@After
public void teardown() throws Exception {
    cleanupCapturedRequests();
    cleanupCapturedResponses();
    if (clientChannel != null) {
        clientChannel.close().syncUninterruptibly();
        clientChannel = null;
    }
    if (serverChannel != null) {
        serverChannel.close().syncUninterruptibly();
        serverChannel = null;
    }
    final Channel serverConnectedChannel = this.serverConnectedChannel;
    if (serverConnectedChannel != null) {
        serverConnectedChannel.close().syncUninterruptibly();
        this.serverConnectedChannel = null;
    }
    Future<?> serverGroup = sb.config().group().shutdownGracefully(0, 5, SECONDS);
    Future<?> serverChildGroup = sb.config().childGroup().shutdownGracefully(0, 5, SECONDS);
    Future<?> clientGroup = cb.config().group().shutdownGracefully(0, 5, SECONDS);
    serverGroup.syncUninterruptibly();
    serverChildGroup.syncUninterruptibly();
    clientGroup.syncUninterruptibly();
}

源代码3 项目： netty-4.1.22 文件： HttpToHttp2ConnectionHandlerTest.java

@After
public void teardown() throws Exception {
    if (clientChannel != null) {
        clientChannel.close().syncUninterruptibly();
        clientChannel = null;
    }
    if (serverChannel != null) {
        serverChannel.close().syncUninterruptibly();
        serverChannel = null;
    }
    final Channel serverConnectedChannel = this.serverConnectedChannel;
    if (serverConnectedChannel != null) {
        serverConnectedChannel.close().syncUninterruptibly();
        this.serverConnectedChannel = null;
    }
    Future<?> serverGroup = sb.config().group().shutdownGracefully(0, 5, SECONDS);
    Future<?> serverChildGroup = sb.config().childGroup().shutdownGracefully(0, 5, SECONDS);
    Future<?> clientGroup = cb.config().group().shutdownGracefully(0, 5, SECONDS);
    serverGroup.syncUninterruptibly();
    serverChildGroup.syncUninterruptibly();
    clientGroup.syncUninterruptibly();
}

源代码4 项目： hivemq-community-edition 文件： NettyShutdownHook.java

@Override
public void run() {
    log.debug("Shutting down worker and boss threads");
    final Future<?> workerFinished = workerGroup.shutdownGracefully(2, timeout, TimeUnit.SECONDS); //TimeUnit effects both parameters!
    final Future<?> bossFinished = bossGroup.shutdownGracefully(2, timeout, TimeUnit.SECONDS);

    log.trace("Waiting for Worker threads to finish");
    workerFinished.syncUninterruptibly();
    log.trace("Waiting for Boss threads to finish");
    bossFinished.syncUninterruptibly();
}

源代码5 项目： redisson 文件： DNSMonitor.java

public DNSMonitor(ConnectionManager connectionManager, RedisClient masterHost, Collection<RedisURI> slaveHosts, long dnsMonitoringInterval, AddressResolverGroup<InetSocketAddress> resolverGroup) {
    this.resolver = resolverGroup.getResolver(connectionManager.getGroup().next());
    
    masterHost.resolveAddr().syncUninterruptibly();
    masters.put(masterHost.getConfig().getAddress(), masterHost.getAddr());
    
    for (RedisURI host : slaveHosts) {
        Future<InetSocketAddress> resolveFuture = resolver.resolve(InetSocketAddress.createUnresolved(host.getHost(), host.getPort()));
        resolveFuture.syncUninterruptibly();
        slaves.put(host, resolveFuture.getNow());
    }
    this.connectionManager = connectionManager;
    this.dnsMonitoringInterval = dnsMonitoringInterval;
}

源代码6 项目： resp-server 文件： RespServer.java

private void closeFuture(Future<?> future) {
  LOGGER.debug("closing future");
  future.syncUninterruptibly();
  LOGGER.debug("future closed");
}

方法所在类

io.netty.util.concurrent.Future