From 549110fbfd384e59790bf93a77048a658f13f991 Mon Sep 17 00:00:00 2001 From: fangzhipeng <124746406@qq.com> Date: Fri, 22 Jun 2018 18:25:30 +0800 Subject: [PATCH] =?UTF-8?q?=E9=82=AE=E7=AE=B1=E7=9B=91=E6=8E=A7=E5=8A=9F?= =?UTF-8?q?=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../netty/rpc/core/protocol/client/NettyClientHandler.java | 7 ------- 1 file changed, 7 deletions(-) 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