写点什么

想要轻松入门 Java 并发编程,那你必须吃透多线程!看这一篇就够了

发布于: 26 分钟前
想要轻松入门Java并发编程,那你必须吃透多线程!看这一篇就够了

今日分享开始啦,请大家多多指教~

一、Executors 的理解

Executors 类属于 java.util.concurrent 包;

线程池的创建分为两种方式:ThreadPoolExecutor 和 Executors;

Executors(静态 Executor 工厂)用于创建线程池;

工厂和工具方法 Executor , ExecutorService , ScheduledExecutorService , ThreadFactory 和 Callable 在此包中定义的类;

jdk1.8API 中的解释如下:

二、Executors 类图结构

三、Executors 常用的方法

public static ExecutorService newFixedThreadPool(int nThreads) 一种线程数量固定的线程池,当线程处于空闲状态时,他们并不会被回收,除非线程池被关闭。当所有的线程都处于活动状态时,新的任务都会处于等待状态,直到有线程空闲出来。

public static ExecutorService newSingleThreadExecutor() 创建单个线程。它适用于需要保证顺序地执行各个任务;并且在任意时间点,不会有多个线程是活动的应用场景;如果单个线程挂掉后,会重启一个线程继续执行任务。

public static ExecutorService newCachedThreadPool() 创建一个根据需要创建新线程的线程池,但在可用时将重新使用以前构造的线程, 如果没有可用的线程,将创建一个新的线程并将其添加到该池中。 未使用六十秒的线程将被终止并从缓存中删除;即用的时候创建线程,不用的时候销毁线程。

- public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) 创建一个线程池,可以调度命令在给定的延迟之后运行,或定期执行;支持执行定时性或周期性任务。

public static ExecutorService newWorkStealingPool(int parallelism) jdk1.8 才出现的,创建一个维护足够的线程以支持给定的并行级别的线程池,并且可以使用多个队列来减少争用。 ( jdk1.8 版本新增的方法 )

四、线程池的创建分为两种方式(主要介绍通过 Executors 类创建的方式)

1、newFixedThreadPool 方法示例

代码

输出结果如下图

结论:示例中创建了数量固定为 3 的线程,由输出结果截图可知,遍历次数为 5 次,当执行一轮(3 次)后,停顿一秒钟,直到有线程空闲出来,才继续第 4 次执行。

2、newSingleThreadExecutor 方法示例

代码

输出结果如下图

结论:示例中创建了创建单个线程,每执行一次任务后,睡眠一秒,保证顺序地执行各个任务。

3、newCachedThreadPool 方法

代码

输出结果如下图

结论:示例中根据需要创建带有缓存线程的线程池,并在可用时将重新使用以前构造的线程。

4、newScheduledThreadPool 方法示例

代码

输出结果如下图

结论:示例中创建执行周期性或定时性任务的线程池,由输出结果可知,设置的 1 分钟后执行任务已经生效。

五、Executors 创建线程池原理

1、无论是创建何种类型线程池(newFixedThreadPool、newSingleThreadExecutor、newCachedThreadPool 等等),均会调用 ThreadPoolExecutor 构造函数。



2、 ThreadPoolExecutor 构造函数中的参数解析

  • corePoolSize 核心线程最大数量,通俗点来讲就是,线程池中常驻线程的最大数量;

  • maximumPoolSize 线程池中运行最大线程数(包括核心线程和非核心线程);

  • keepAliveTime 线程池中空闲线程(仅适用于非核心线程)所能存活的最长时间;

  • unit 存活时间单位,与 keepAliveTime 搭配使用;

  • workQueue 存放任务的阻塞队列;

  • handler 线程池饱和策略。

六、Executor 接口的理解

Executor 属于 java.util.concurrent 包下;

Executor 是任务执行机制的核心接口;

七、Executor 接口的类图结构

由类图结构可知:

ThreadPoolExecutor 继承了 AbstractExecutorService 接口;

AbstractExecutorService 接口实现了 ExecutorService 接口;

ExecutorService 继承了 Executor 接口;

因此以下部分主要讲解 ThreadPoolExecutor 类。

八、Executor 接口中常用的方法

void execute(Runnable command) 在将来的某个时间执行给定的命令。 该命令可以在一个新线程,一个合并的线程中或在调用线程中执行,由 Executor 实现。

九、线程池的创建分为两种方式(主要介绍通过 ThreadPoolExecutor 方式)

1、ThreadPoolExecutor 类中的构造方法

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue workQueue,defaultHandler)

2、 ThreadPoolExecutor 类中构造函数的参数解析

  • corePoolSize 核心线程最大数量,通俗点来讲就是,线程池中常驻线程的最大数量;

  • maximumPoolSize 线程池中运行最大线程数(包括核心线程和非核心线程);

  • keepAliveTime 线程池中空闲线程(仅适用于非核心线程)所能存活的最长时间;

  • unit 存活时间单位,与 keepAliveTime 搭配使用;

  • workQueue 存放任务的阻塞队列;

  • handler 线程池饱和策略。

3、ThreadPoolExecutor 类创建线程池示例

代码

输出结果如下图

结论:无论是创建何种类型线程池(newFixedThreadPool、newSingleThreadExecutor、newCachedThreadPool 等等),均会调用 ThreadPoolExecutor 构造函数。


今日份分享已结束,请大家多多包涵和指点!

用户头像

还未添加个人签名 2021.04.20 加入

Java工具与相关资料获取等WX: pfx950924(备注来源)

评论

发布
暂无评论
想要轻松入门Java并发编程,那你必须吃透多线程!看这一篇就够了