Toggle navigation
Home
java.util.concurrent.ExecutorService to io.vertx.core.impl.WorkerPool
No. of Instances - 2
No. of Commits - 1
No. of Projects - {'vert.x'}
Hierarchy/Composition: Composition
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
workerPoolMetrics.close()
to
workerPool.close()
workerPool.shutdownNow()
to
workerPool.close()
internalBlockingPoolMetrics.close()
to
workerPool.close()
internalBlockingPool.shutdownNow()
to
workerPool.close()
workerPoolMetrics.close()
to
workerPool.close()
workerPool.shutdownNow()
to
workerPool.close()
internalBlockingPoolMetrics.close()
to
workerPool.close()
internalBlockingPool.shutdownNow()
to
workerPool.close()
Update Anonymous class
{ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down acceptor event loop group",future.cause()); } eventLoopGroup.shutdownGracefully(0,10,TimeUnit.SECONDS).addListener(new GenericFutureListener(){ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down event loop group",future.cause()); } if (metrics != null) { metrics.close(); } checker.close(); if (completionHandler != null) { eventLoopThreadFactory.newThread(() -> { completionHandler.handle(Future.succeededFuture()); } ).start(); } } } ); } }
to
{ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down acceptor event loop group",future.cause()); } eventLoopGroup.shutdownGracefully(0,10,TimeUnit.SECONDS).addListener(new GenericFutureListener(){ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down event loop group",future.cause()); } if (metrics != null) { metrics.close(); } checker.close(); if (completionHandler != null) { eventLoopThreadFactory.newThread(() -> { completionHandler.handle(Future.succeededFuture()); } ).start(); } } } ); } }
{ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down acceptor event loop group",future.cause()); } eventLoopGroup.shutdownGracefully(0,10,TimeUnit.SECONDS).addListener(new GenericFutureListener(){ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down event loop group",future.cause()); } if (metrics != null) { metrics.close(); } checker.close(); if (completionHandler != null) { eventLoopThreadFactory.newThread(() -> { completionHandler.handle(Future.succeededFuture()); } ).start(); } } } ); } }
to
{ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down acceptor event loop group",future.cause()); } eventLoopGroup.shutdownGracefully(0,10,TimeUnit.SECONDS).addListener(new GenericFutureListener(){ @Override public void operationComplete( io.netty.util.concurrent.Future future) throws Exception { if (!future.isSuccess()) { log.warn("Failure in shutting down event loop group",future.cause()); } if (metrics != null) { metrics.close(); } checker.close(); if (completionHandler != null) { eventLoopThreadFactory.newThread(() -> { completionHandler.handle(Future.succeededFuture()); } ).start(); } } } ); } }