JAVA 线程池与NIO Socket链接

JAVA线程池

核心类 ThreadPoolExecutor,实例化需要指定一个队列。
跟Tomcat一样，有一个固定数量线程的线程池并且有一个请求队列，当
处理请求的线程已经用完时(所有线程处于工作状态时)，所有请求都会放在队列中，而ThreadPoolExecutor也是一个道理。

//实例化一个只能存放3个请求的线程
 BlockingQueue queue = new ArrayBlockingQueue(3);
//实例化一个最多2条用于处理请求线程,当线程池用完其他请求会存放在queue 中
 ExecutorService executor = new ThreadPoolExecutor(1, 2, 1, TimeUnit.DAYS, queue);

//注意ThreadPoolExecutor实例化所需要队列接口为BlockingQueue 
//表示同一时间只会有一个请求放到队列中

定义请求处理器(即请求)

class Handler implements Runnable {
        @Override
        public void run() {
            log("处理请求代码");
        }
    }

执行请求处理

Handler  handler = new Handler();
//如果当前线程池所有线程都用完时，该handler不会被执行，直到有空闲的线程时。
executor.execute(handler);

NIO Socket服务端

那么问题来了,配合NIO Socket循环接受连接
就会有可能导致
连接长时间处于连接而同时又是待处理状态:

while (true) {
 log("Start accept");
 SocketChannel socketChannel = serverSocketChannel.accept();
            if (socketChannel == null) {
                log("new Connection is null");
            } else {
                log("new Connection,ip:%s", socketChannel.getRemoteAddress());
                OnConnection connection = new OnConnection(socketChannel);
                //当线程用完时,连接会被放到队列queue中,直到线程池中有空闲的线程
                //如果这些客户端连接一直处于等待而不断开连接状态,那么queue会一直被堆满，
                //并且由于连接没有释放导致内存一直积压
                executor.execute(connection);
            }
}

所以一个合理的C/S交互是应该设计超时策略,当超时时间内对方(S或C)无法响应,则应该断开连接。