Tomcat 第四篇：请求处理流程（上） (3)

接着看下 startInternal() 方法：

/** * Start the APR endpoint, creating acceptor, poller and sendfile threads. */ @Override public void startInternal() throws Exception { if (!running) { running = true; paused = false; processorCache = new SynchronizedStack<>(SynchronizedStack.DEFAULT_SIZE, socketProperties.getProcessorCache()); // Create worker collection if (getExecutor() == null) { createExecutor(); } initializeConnectionLatch(); // Start poller thread poller = new Poller(); poller.init(); Thread pollerThread = new Thread(poller, getName() + "-Poller"); pollerThread.setPriority(threadPriority); pollerThread.setDaemon(true); pollerThread.start(); // Start sendfile thread if (getUseSendfile()) { sendfile = new Sendfile(); sendfile.init(); Thread sendfileThread = new Thread(sendfile, getName() + "-Sendfile"); sendfileThread.setPriority(threadPriority); sendfileThread.setDaemon(true); sendfileThread.start(); } startAcceptorThreads(); } }

这个方法所有的前提条件都在于如果 AprEndpoint 尚未出于运行中，即 running == true ，首先如果没有创建线程池 getExecutor() == null ，则需要调用 createExecutor() 方法创建线程池和任务队列 TaskQueue 。

public void createExecutor() { internalExecutor = true; TaskQueue taskqueue = new TaskQueue(); TaskThreadFactory tf = new TaskThreadFactory(getName() + "-exec-", daemon, getThreadPriority()); executor = new ThreadPoolExecutor(getMinSpareThreads(), getMaxThreads(), 60, TimeUnit.SECONDS,taskqueue, tf); taskqueue.setParent( (ThreadPoolExecutor) executor); }

剩下两个是创建了两个线程，分别是 poller 和 sendfile ，这两个都是 AprEndpoint 的内部类，这两个线程一个是用来做轮询，另一个是用来做数据发送。

至此， Tomcat 中为请求处理的准备工作已经完成。