Skip to content

Commit

Permalink
邮箱监控功能
Browse files Browse the repository at this point in the history
  • Loading branch information
forezp committed Jun 22, 2018
1 parent 92fac21 commit 549110f
Showing 1 changed file with 0 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 549110f

Please sign in to comment.