线程池参数详解

        public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory,
                              RejectedExecutionHandler handler)
    

jdk内置的线程池

1. Executors.newFixedThreadPool(int)
2. Executors.newSingleThreadExecutor()
3. Executors.newCachedThreadPool()

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

在newFixedThreadPool和newSingleThreadExecutor中阻塞队列均采用默认的LinkedBlockingQueue导致这个阻塞队列的长度达到Integer.MAX_VALUE，当某一时刻有大量的任务涌入线程池中容易导致JVM发生OOM问题

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

而在newCachedThreadPool中采用的是SynchronousQueue这种阻塞队列，该队列任意时刻最多只能有一个元素并且一个put操作必须等待另一个take操作完成。它并不是一个容器，可以认为它是一个快速交换信息的通道。虽然该队列对外的size为0，但由于该线程池的定义maximumPoolSize为Integer.MAX_VALUE，当有大量任务涌入时则会创建出大量的线程Thread对象导致OOM等问题。

虽然在JDK中内置了已经定义好的线程池但是在生产环境下应该尽量使用自己自定义的线程池

线程池执行流程

1. 在创建了线程池后，等待提交过来的任务请求。
2. 当调用execute()方法添加一个请求任务时，线程池会做如下判断。
   2.1 如果正在运行的线程数量小于corePoolSize，那么马上创建线程运行这个任务。
   2.2 如果正在运行的线程数量大于或等于corePoolSize，那么将这个任务加入队列。
   2.3 如果这时候队列满了且正在运行的线程数量还小于maximumPoolSize，那么还是要创建非核心线程立刻运行这个任务。
   2.4 如果队列满了且正在运行的线程数量大于或等于maximumPoolSize，那么线程池会启动饱和拒绝策略来执行。
3. 当一个线程完成任务时，它会从队列中取下一个任务来执行。
4. 当一个线程无事可做超过一定的时间(keepAliveTime)时，线程池会判断：如果当前运行的线程数大于corePoolSize，那么这个线程就会被停掉。

注意：LinkedBlockingQueue是一个无界（界限为Integer.MAX_VALUE）缓存等待队列。当前执行的线程数量达到corePoolSize的数量时，剩余的元素会在阻塞队列里等待。（所以在使用此阻塞队列时maximumPoolSizes就相当于无效了）。

线程数的选择

CPU密集型任务配置尽可能少的线程数量：
一般公式：CPU核数+1个线程的线程池

由于IO密集型任务线程并不是一直在执行任务，则应配置尽可能多的线程，如CPU核数*2

IO密集型，即该任务需要大量的IO，即大量的阻塞。
在单线程上运行IO密集型的任务会导致浪费大量的CPU运算能力浪费在等待。
所以在IO密集型任务中使用多线程可以大大的加速程序运行，即使在单核CPU上，这种加速主要就是利用了被浪费掉的阻塞时间。

IO密集型时，大部分线程都阻塞，故需要多配置线程数：
参考公式：CPU核数/(1-阻塞系统) 阻塞系数在0.8~0.9之间
比如8核CPU：8/(1-0.9)=80个线程数

原文：https://www.cnblogs.com/cjunn/p/12232751.html