本文整理了Java中io.netty.channel.nio.NioEventLoopGroup.terminationFuture()
方法的一些代码示例,展示了NioEventLoopGroup.terminationFuture()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NioEventLoopGroup.terminationFuture()
方法的具体详情如下:
包路径:io.netty.channel.nio.NioEventLoopGroup
类名称:NioEventLoopGroup
方法名:terminationFuture
暂无
代码示例来源:origin: glowroot/glowroot
static EventLoopGroup create(String name) {
final ExecutorService executor = Executors.newSingleThreadExecutor(
new ThreadFactoryBuilder()
.setDaemon(true)
.setNameFormat(name)
.build());
NioEventLoopGroup nioEventLoopGroup = new NioEventLoopGroup(1, executor);
nioEventLoopGroup.terminationFuture()
.addListener(new GenericFutureListener<Future</*@Nullable*/ Object>>() {
@Override
public void operationComplete(Future</*@Nullable*/ Object> future)
throws Exception {
executor.shutdown();
if (!executor.awaitTermination(10, SECONDS)) {
throw new IllegalStateException("Could not terminate executor");
}
}
});
return nioEventLoopGroup;
}
}
代码示例来源:origin: glowroot/glowroot
static EventLoopGroup create(String name) {
final ExecutorService executor =
Executors.newSingleThreadExecutor(ThreadFactories.create(name));
NioEventLoopGroup nioEventLoopGroup = new NioEventLoopGroup(1, executor);
nioEventLoopGroup.terminationFuture()
.addListener(new GenericFutureListener<Future</*@Nullable*/ Object>>() {
@Override
public void operationComplete(Future</*@Nullable*/ Object> future)
throws Exception {
executor.shutdown();
if (!executor.awaitTermination(10, SECONDS)) {
throw new IllegalStateException("Could not terminate executor");
}
}
});
return nioEventLoopGroup;
}
}
代码示例来源:origin: org.apache.carbondata/carbondata-core
/**
* shutdown dictionary client
*/
@Override public void shutDown() {
workerGroup.shutdownGracefully();
try {
workerGroup.terminationFuture().sync();
} catch (InterruptedException e) {
LOGGER.error(e);
}
}
}
代码示例来源:origin: com.linkedin.pegasus/r2-netty
@Override
public void waitForStop() throws InterruptedException
{
_bossGroup.terminationFuture().await();
_workerGroup.terminationFuture().await();
_eventExecutors.terminationFuture().await();
}
}
代码示例来源:origin: io.netty/netty-testsuite
connectGroup.shutdownGracefully();
acceptGroup.terminationFuture().syncUninterruptibly();
connectGroup.terminationFuture().syncUninterruptibly();
内容来源于网络,如有侵权,请联系作者删除!