本文共 1129 字，大约阅读时间需要 3 分钟。

startInternal():创建worker线程池,初始化Poller线程，根据可以用的处理器的数目，我的机器是双核超线程的，所以为4.

Poller是连接器的关键，不断地轮询分发连接，交给worker线程去处理。

// Create worker collection            if ( getExecutor() == null ) {                createExecutor();//如在server.xml,没有配置executor,则创建默认的连接池，poolSize为200            }            initializeConnectionLatch();                        // Start poller threads            pollers = new Poller[getPollerThreadCount()];            for (int i=0; i

 在Poller的run方法内有如下代码：

if ( !close ) {                            if (wakeupCounter.get()>0) {                                //if we are here, means we have other stuff to do                                //do a non blocking select                                keyCount = selector.selectNow();                            }else {                                keyCount = selector.keys().size();                                wakeupCounter.set(-1);                                keyCount = selector.select(selectorTimeout);//NIO关键，看注册的channel有没有事件发生                            }                            wakeupCounter.set(0);                        }

转载地址：http://bmdmi.baihongyu.com/