邮箱监控功能

forezp · Jun 22, 2018 · 549110f · 549110f
1 parent 92fac21
commit 549110f
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/...ore/src/main/java/io/github/forezp/netty/rpc/core/protocol/client/NettyClientHandler.java b/...ore/src/main/java/io/github/forezp/netty/rpc/core/protocol/client/NettyClientHandler.java
@@ -37,13 +37,6 @@ public NettyClientHandler(ExcutorContainer excutorContainer) {
  @Override
  protected void channelRead0(ChannelHandlerContext ctx, final NettyRpcResponse response) throws Exception {
 
- ThreadPoolExecutor executor = ThreadPoolFactory.createClientPoolExecutor( response.getInterfaze() );
-
- int coreSize = executor.getCorePoolSize();
- int activeCount = executor.getActiveCount();
- int queueSize = executor.getQueue().size();
- System.out.println( "executor" + executor.toString() + " coreSize:" + coreSize + " activeCount:" + activeCount + " queueSize :" + queueSize );
-
  ThreadPoolFactory.createClientPoolExecutor( response.getInterfaze() ).submit( new Callable<NettyRpcResponse>() {
 
  @Override