线程池的种类

线程池的种类

之前说过ThreadPoolExecutor的用法，jdkExecutors包下还封装了一些其他类型的线程池。

newFixedThreadPool

public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

顾名思义，就是创建线程数量固定的线程池，线程池的corePoolSize和maximumPoolSize大小一样，并且keepAliveTime为0，传入的队列LinkedBlockingQueue为无界队列。在说ThreadPoolExecutor的时候也说过，传入一个无界队列，maximumPoolSize参数是不起作用的。

newSingleThreadExecutor

public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue<Runnable>()));
    }

从代码中也能看得出来，corePoolSize和maximumPoolSize都是1，keepAliveTime是0L, 传入的队列是无界队列。线程池中永远只要一个线程在工作。

newCachedThreadPool

public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>());
    }

可缓存线程池，说道缓存一般离不开过期时间，该线程池也是，corePoolSize设置为0，maximumPoolSize设置为int最大值，不同的是，线程池传入的队列是SynchronousQueue，一个同步队列，该队列没有任何容量，每次插入新数据，必须等待消费完成。当有新任务到达时，线程池没有线程则创建线程处理，处理完成后该线程缓存60秒，过期后回收，线程过期前有新任务到达时，则使用缓存的线程来处理。

newScheduledThreadPool

public static ScheduledExecutorService newScheduledThreadPool(
            int corePoolSize, ThreadFactory threadFactory) {
        return new ScheduledThreadPoolExecutor(corePoolSize, threadFactory);
    }

这个线程池使用了ScheduledThreadPoolExecutor，该线程池继承自ThreadPoolExecutor, 执行任务的时候可以指定延迟多少时间执行，或者周期性执行。