diff --git a/boot-netty-rpc-core/src/main/java/io/github/forezp/netty/rpc/core/protocol/client/NettyClientHandler.java b/boot-netty-rpc-core/src/main/java/io/github/forezp/netty/rpc/core/protocol/client/NettyClientHandler.java index 8f1f1ec..2f4ca78 100644 --- a/boot-netty-rpc-core/src/main/java/io/github/forezp/netty/rpc/core/protocol/client/NettyClientHandler.java +++ b/boot-netty-rpc-core/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() { @Override