二十一 线程池

1. 在大多数应用场景下，使用 Executors 提供的 下面5 个静态工厂方法就足够了:

• newCachedThreadPool()，它是一种用来处理大量短时间工作任务的线程池，具有几个鲜明特点：它会试图缓存线程并重用，当无缓存线程可用时，就会创建新的工作线程；如果线程闲置的时间超过 60 秒，则被终止并移出缓存；长时间闲置时，这种线程池，不会消耗什么资源。其内部使用 SynchronousQueue 作为工作队列。
• newFixedThreadPool(int nThreads)，重用指定数目（nThreads）的线程，其背后使用的是无界的工作队列，任何时候最多有 nThreads 个工作线程是活动的。这意味着，如果任务数量超过了活动队列数目，将在工作队列中等待空闲线程出现；如果有工作线程退出，将会有新的工作线程被创建，以补足指定的数目 nThreads。
• newSingleThreadExecutor()，它的特点在于工作线程数目被限制为 1，操作一个无界的工作队列，所以它保证了所有任务的都是被顺序执行，最多会有一个任务处于活动状态，并且不允许使用者改动线程池实例，因此可以避免其改变线程数目。
• newSingleThreadScheduledExecutor() 和 newScheduledThreadPool(int corePoolSize)，创建的是个 ScheduledExecutorService，可以进行定时或周期性的工作调度，区别在于单一工作线程还是多个工作线程。
• newWorkStealingPool(int parallelism)，这是一个经常被人忽略的线程池，Java 8 才加入这个创建方法，其内部会构建ForkJoinPool，利用Work-Stealing算法，并行地处理任务，不保证处理顺序。

2. 线程池(ExecutorService 父接口 Executor)这个定义就是个容易让人误解的术语，因为它除了通常意义上“池”的功能，还提供了更全面的线程管理、任务提交等方法.

   
   图片.png

线程池构造方法
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler)

3. 线程池注意:

• 避免任务堆积 如newFixedThreadPool是创建指定数目线程, 但其工作队列是无界的. 如果处理跟不上入队, 就可能占用大量内存,甚至OOM
• 避免过度扩展线程
• 如果线程数目不断增长(可用jstack检查) 警惕线程泄漏, 往往因为任务逻辑有问题,导致工作线程迟迟不能释放
• 避免死锁
• 避免在用线程池时使用ThreadLocal

4. 线程池大小设定

• 如果主要任务是计算, 则设定为cpu核数目N 或 N+1
  避免线程上下文切换造成的损耗

• 如果是需要较多等待的工作, 如IO 则推荐
  线程数 = CPU 核数 × （1 + 平均等待时间 / 平均工作时间）
  因为io这些操作并不占用cpu,不要让cpu空闲下来,即加大线程数量