几种Java线程池的实现算法分析

实现

工作者workers结构与并发保护

待处理工作队列结构

JDK

使用了HashSet来存储工作者workers，通过可重入锁ReentrantLock对其进行并发保护。每个worker都是一个Runnable接口。

使用了实现接口BlockingQueue的阻塞队列来存储待处理工作job，并把队列作为构造函数参数，从而实现业务可以灵活的扩展定制线程池的队列。业务也可使用JDK自身的同步阻塞队列SynchronousQueue、有界队列ArrayBlockingQueue、无界队列LinkedBlockingQueue、优先级队列PriorityBlockingQueue。

Jetty6

同样使用了HashSet存储工作者workers，通过synchronized一个对象进行HashSet的并发保护。每个工作者实际上是一个Thread的扩展。

使用了数组存储待处理的job对象Runnable。数组初始化容量为_maxThreads个，使用变量_queued计算保存当前内部待处理job的个数即数组length。超过数组最大值时，扩大_maxThreads个容量，因此数组永远够用够大，容量无界。同样是用synchronized一个对象的方式实现同步。

Jetty8

使用了ConcurrentLinkedQueue存储工作者workers，利用JDK基于CAS算法的实现提高了并发效率，同时也降低了线程池并发保护的复杂程度。针对队列ConcurrentLinkedQueue无法保证size()实时性问题引入原子变量AtomicInteger统计工作者数量。

与JDK相同实现，使用了基于接口BlockingQueue的阻塞队列来存储待处理工作job，也支持在线程池构造函数的参数中传入队列类型。同时，Jetty8内部默认未设置队列类型场景可自动设置使用2种队列：有界无法扩容的ArrayBlockingQueue及Jetty自身定制扩展实现的可扩容队列BlockingArrayQueue。

Tomcat

基于JDK的ThreadPoolExecutors实现，复用JDK业务

复用JDK业务