深入浅出JAVA线程池使用原理2

Posted 2021-02-15 Lucky帅小武

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了深入浅出JAVA线程池使用原理2相关的知识，希望对你有一定的参考价值。

一、Executor框架介绍

Executor框架将Java多线程程序分解成若干个任务，将这些任务分配给若干个线程来处理，并得到任务的结果

1.1、Executor框架组成

任务：被执行任务需要实现的接口：Runnable接口或Callable接口

任务的执行：任务执行的核心接口Executor以及其子类ExecutorService接口

任务的结果：包括Future接口以及Future接口的实现类FutureTask类

Executor接口是Executor框架的基础，将任务的提交与执行分离开

ThreadPoolExecutor：线程池核心实现类，用来执行提交的任务

ScheduledThreadPoolExecutor：在给定的延迟时间后执行或定期执行任务，相当于ThreadPoolExecutor的定时器版本

Future接口和实现类FutureTask代表异步处理的结果

Runnable接口和Callable接口都是当做任务被ThreadPoolExecutor和ScheduledThreadPoolExecutor来执行

二、ThreadPoolExecutor详解

ThreadPoolExecutor通常可以使用工厂类Executors来创建，可以有以下三种类型：

SingleThreadExecutor：单线程线程池执行器，适用于需要保证顺序地执行各个任务且不会出现多线程同时活动的情况

FixedThreadPool：创建使用固定线程数量的线程池，可以限制当前线程数量，比较常用。

CachedThreadPool：大小无界的线程池，适用于需要执行大量短期异步任务的场景或者是服务器负载较小的情况

2.1、FixedThreadPool详解

源码如下：

1 public static ExecutorService newFixedThreadPool(int nThreads, ThreadFactory threadFactory) {
2         return new ThreadPoolExecutor(nThreads, nThreads,
3                                       0L, TimeUnit.MILLISECONDS,
4                                       new LinkedBlockingQueue<Runnable>(),
5                                       threadFactory);
6     }

可以看出只需要设置两个参数：线程数量和线程工厂（可不传）

1.这里可以看出FixedThreadPool使用的工作队列是无界的链表结构的阻塞队列，所以这里的maximumPoolSize参数就设置成了和coolPoolSize一样的值，因为设置再大也失去了意义；

2.多余线程保持活跃的时间设置成了0，也就是多余的空闲线程会立即终止；

3.由于队列是无界的，所以线程池不会出现拒绝任务的情况，所以也不会用到饱和策略；

4.整体的工作流程就是：

线程池中线程数量少于corePoolSize时会先创建新线程来预热，达到之后就将任务放入LinkedBlockingQueue队列中，线程执行完任务之后会循环从队列中获取任务来执行

2.2、SingleThreadExecutor详解

源码如下：

1 public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {
2         return new FinalizableDelegatedExecutorService
3             (new ThreadPoolExecutor(1, 1,
4                                     0L, TimeUnit.MILLISECONDS,
5                                     new LinkedBlockingQueue<Runnable>(),
6                                     threadFactory));
7     }

可以看出SingleThreadExecutor和FixedThreadPool几乎一样，只是线程只会有一个线程，相比于FixedThreadPool的好处就是可以保证任务的顺序性

2.3、CachedThreadPool详解

源码如下：

1 public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory) {
2         return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
3                                       60L, TimeUnit.SECONDS,
4                                       new SynchronousQueue<Runnable>(),
5                                       threadFactory);
6     }