如何判断线程池已经执行完所有任务了？

目录

不判断的问题

方法1：isTerminated

缺点分析

扩展：线程池的所有状态

方法2：getCompletedTaskCount

方法说明

优缺点分析

方法3：CountDownLatch（推荐）

优缺点分析

方法4：CyclicBarrier

方法说明

优缺点分析

总结

很多场景下，我们需要等待线程池的所有任务都执行完，然后再进行下一步操作。对于线程 Thread 来说，很好实现，加一个 join 方法(主线程”等待“子线程”结束之后才能继续运行)就解决了，然而对于线程池的判断就比较麻烦了。

我们本文提供 4 种判断线程池任务是否执行完的方法：

  1. 使用 isTerminated 方法判断。
  2. 使用 getCompletedTaskCount 方法判断。
  3. 使用 CountDownLatch 判断。
  4. 使用 CyclicBarrier 判断。

接下来我们一个一个来看。

不判断的问题

如果不对线程池是否已经执行完做判断，就会出现以下问题，如下代码所示：

import java.util.Random;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;public class ThreadPoolCompleted {public static void main(String[] args) {// 创建线程池ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));// 添加任务addTask(threadPool);// 打印结果System.out.println("线程池任务执行完成！");}/*** 给线程池添加任务*/private static void addTask(ThreadPoolExecutor threadPool) {// 任务总数final int taskCount = 5;// 添加任务for (int i = 0; i < taskCount; i++) {final int finalI = i;threadPool.submit(new Runnable() {@Overridepublic void run() {try {// 随机休眠 0-4sint sleepTime = new Random().nextInt(5);TimeUnit.SECONDS.sleep(sleepTime);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(String.format("任务%d执行完成", finalI));}});}}
}

以上程序的执行结果如下：
 

从上述执行结果可以看出，程序先打印了“线程池任务执行完成！”，然后还在陆续的执行线程池的任务，这种执行顺序混乱的结果，并不是我们期望的结果。我们想要的结果是等所有任务都执行完之后，再打印“线程池任务执行完成！”的信息。

产生以上问题的原因是因为主线程 main和线程池是并发执行的，所以当线程池还没执行完，main 线程的打印结果代码就已经执行了。想要解决这个问题，就需要在打印结果之前，先判断线程池的任务是否已经全部执行完，如果没有执行完，就等待任务执行完再执行打印结果。

 

方法1：isTerminated

我们可以利用线程池的终止状态（TERMINATED）来判断线程池的任务是否已经全部执行完，但想要线程池的状态发生改变，我们就需要调用线程池的 shutdown 方法，不然线程池一直会处于 RUNNING 运行状态，那就没办法使用终止状态来判断任务是否已经全部执行完了，它的实现代码如下：

import java.util.Random;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** 线程池任务执行完成判断*/
public class ThreadPoolCompleted {public static void main(String[] args) {// 1.创建线程池ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));// 2.添加任务addTask(threadPool);// 3.判断线程池是否执行完isCompleted(threadPool); // 【核心调用方法】// 4.线程池执行完System.out.println();System.out.println("线程池任务执行完成！");}/*** 方法1：isTerminated 实现方式* 判断线程池的所有任务是否执行完*/private static void isCompleted(ThreadPoolExecutor threadPool) {threadPool.shutdown();while (!threadPool.isTerminated()) { // 如果没有执行完就一直循环}}/*** 给线程池添加任务*/private static void addTask(ThreadPoolExecutor threadPool) {// 任务总数final int taskCount = 5;// 添加任务for (int i = 0; i < taskCount; i++) {final int finalI = i;threadPool.submit(new Runnable() {@Overridepublic void run() {try {// 随机休眠 0-4sint sleepTime = new Random().nextInt(5);TimeUnit.SECONDS.sleep(sleepTime);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(String.format("任务%d执行完成", finalI));}});}}
}

方法说明：shutdown 方法是启动线程池有序关闭的方法，它在完全关闭之前会执行完之前所有已经提交的任务，并且不会再接受任何新任务。当线程池中的所有任务都执行完之后，线程池就进入了终止状态，调用 isTerminated 方法返回的结果就是 true 了。

以上程序的执行结果如下：

缺点分析

需要关闭线程池。

扩展：线程池的所有状态

线程池总共包含以下 5 种状态：

  • RUNNING：运行状态。
  • SHUTDOWN：关闭状态。
  • STOP：阻断状态。
  • TIDYING：整理状态。
  • TERMINATED：终止状态

如果不调用线程池的关闭方法，那么线程池会一直处于 RUNNING 运行状态。

方法2：getCompletedTaskCount

我们可以通过判断线程池中的计划执行任务数和已完成任务数，来判断线程池是否已经全部执行完，如果计划执行任务数=已完成任务数，那么线程池的任务就全部执行完了，否则就未执行完，具体实现代码如下：

/*** 方法2：getCompletedTaskCount 实现方式* 判断线程池的所有任务是否执行完*/
private static void isCompletedByTaskCount(ThreadPoolExecutor threadPool) {while (threadPool.getTaskCount() != threadPool.getCompletedTaskCount()) {}
}

以上程序执行结果如下：

方法说明
  • getTaskCount()：返回计划执行的任务总数。由于任务和线程的状态可能在计算过程中动态变化，因此返回的值只是一个近似值。
  • getCompletedTaskCount()：返回完成执行任务的总数。因为任务和线程的状态可能在计算过程中动态地改变，所以返回的值只是一个近似值，但是在连续的调用中并不会减少。
优缺点分析

此实现方法的优点是无需关闭线程池。
它的缺点是 getTaskCount() 和 getCompletedTaskCount() 返回的是一个近似值，因为线程池中的任务和线程的状态可能在计算过程中动态变化，所以它们两个返回的都是一个近似值。

方法3：CountDownLatch（推荐）

CountDownLatch 可以理解为一个计数器，我们创建了一个包含 N 个任务的计数器，每个任务执行完计数器 -1，直到计数器减为 0 时，说明所有的任务都执行完了，就可以执行下一段业务的代码了。

具体实现代码如下：

public static void main(String[] args) throws InterruptedException {// 创建线程池ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));final int taskCount = 5;    // 任务总数// 单次计数器CountDownLatch countDownLatch = new CountDownLatch(taskCount); // ①// 添加任务for (int i = 0; i < taskCount; i++) {final int finalI = i;threadPool.submit(new Runnable() {@Overridepublic void run() {try {// 随机休眠 0-4sint sleepTime = new Random().nextInt(5);TimeUnit.SECONDS.sleep(sleepTime);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(String.format("任务%d执行完成", finalI));// 线程执行完，计数器 -1countDownLatch.countDown();  // ②}});}// 阻塞等待线程池任务执行完countDownLatch.await();  // ③// 线程池执行完System.out.println();System.out.println("线程池任务执行完成！");
}

代码说明：以上代码中标识为 ①、②、③ 的代码行是核心实现代码，其中：
① 是声明一个包含了 5 个任务的计数器；
② 是每个任务执行完之后计数器 -1；
③ 是阻塞等待计数器 CountDownLatch 减为 0，表示任务都执行完了，可以执行 await 方法后面的业务代码了。

以上程序的执行结果如下：

优缺点分析

CountDownLatch 写法很优雅，且无需关闭线程池，但它的缺点是只能使用一次，CountDownLatch 创建之后不能被重复使用，也就是说 CountDownLatch 可以理解为只能使用一次的计数器。

方法4：CyclicBarrier

CyclicBarrier 和 CountDownLatch 类似，它可以理解为一个可以重复使用的循环计数器，CyclicBarrier 可以调用 reset 方法将自己重置到初始状态，CyclicBarrier 具体实现代码如下：

public static void main(String[] args) throws InterruptedException {// 创建线程池ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));final int taskCount = 5;    // 任务总数// 循环计数器 ①CyclicBarrier cyclicBarrier = new CyclicBarrier(taskCount, new Runnable() {@Overridepublic void run() {// 线程池执行完System.out.println();System.out.println("线程池所有任务已执行完！");}});// 添加任务for (int i = 0; i < taskCount; i++) {final int finalI = i;threadPool.submit(new Runnable() {@Overridepublic void run() {try {// 随机休眠 0-4sint sleepTime = new Random().nextInt(5);TimeUnit.SECONDS.sleep(sleepTime);System.out.println(String.format("任务%d执行完成", finalI));// 线程执行完cyclicBarrier.await(); // ②} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}});}
}

以上程序的执行结果如下：

方法说明

CyclicBarrier 有 3 个重要的方法：

  1. 构造方法：构造方法可以传递两个参数，参数 1 是计数器的数量 parties，参数 2 是计数器为 0 时，也就是任务都执行完之后可以执行的事件（方法）。
  2. await 方法：在 CyclicBarrier 上进行阻塞等待，当调用此方法时 CyclicBarrier 的内部计数器会 -1，直到发生以下情形之一：
    • 在 CyclicBarrier 上等待的线程数量达到 parties，也就是计数器的声明数量时，则所有线程被释放，继续执行。
    • 当前线程被中断，则抛出 InterruptedException 异常，并停止等待，继续执行。
    • 其他等待的线程被中断，则当前线程抛出 BrokenBarrierException 异常，并停止等待，继续执行。
    • 其他等待的线程超时，则当前线程抛出 BrokenBarrierException 异常，并停止等待，继续执行。
    • 其他线程调用 CyclicBarrier.reset() 方法，则当前线程抛出 BrokenBarrierException 异常，并停止等待，继续执行。
  3. reset 方法：使得CyclicBarrier回归初始状态，直观来看它做了两件事：
    1. 如果有正在等待的线程，则会抛出 BrokenBarrierException 异常，且这些线程停止等待，继续执行。
    2. 将是否破损标志位 broken 置为 false。
优缺点分析

CyclicBarrier 从设计的复杂度到使用的复杂度都高于 CountDownLatch，相比于 CountDownLatch 来说它的优点是可以重复使用（只需调用 reset 就能恢复到初始状态），缺点是使用难度较高。

 

总结

我们本文提供 4 种判断线程池任务是否执行完的方法：

  1. 使用 isTerminated 方法判断：通过判断线程池的完成状态来实现，需要关闭线程池，一般情况下不建议使用。
  2. 使用 getCompletedTaskCount 方法判断：通过计划执行总任务量和已经完成总任务量，来判断线程池的任务是否已经全部执行，如果相等则判定为全部执行完成。但因为线程个体和状态都会发生改变，所以得到的是一个大致的值，可能不准确。
  3. 使用 CountDownLatch 判断：相当于一个线程安全的单次计数器，使用比较简单，且不需要关闭线程池，是比较常用的判断方法。
  4. 使用 CyclicBarrier 判断：相当于一个线程安全的重复计数器，但使用较为复杂，所以日常项目中使用的较少。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://xiahunao.cn/news/2774095.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

VS Code中主程序C文件引用了另一个.h头文件，编译时报错找不到函数

VS Code中主程序C文件引用了另一个.h头文件，编译时报错找不到函数

目录 一、问题描述二、问题原因三、解决方法四、扩展五、通过CMake进行配置 一、问题描述 VS Code中主程序C文件引用了另一个.h头文件&#xff0c;编译时报错找不到函数 主程序 main.c #include <stdio.h> #include "sumaa.h"int main(int, char**){printf(&q…
阅读更多...
【Python基础】案例分析：电影分析

【Python基础】案例分析：电影分析

电影分析 项目背景&#xff1a; 数据集介绍&#xff1a;movie_lens数据集是一个电影信息&#xff0c;电影评分的数据集&#xff0c;可以用来做推荐系统的数据集需求&#xff1a;对电影发展&#xff0c;类型&#xff0c;评分等做统计分析。目标&#xff1a;巩固pandas相关知识…
阅读更多...
《幻兽帕鲁》攻略：0基础入门及游戏基础操作 幻兽帕鲁基础设施 幻兽帕鲁基础攻击力 Mac苹果电脑玩幻兽帕鲁 幻兽帕鲁加班加点

《幻兽帕鲁》攻略：0基础入门及游戏基础操作 幻兽帕鲁基础设施 幻兽帕鲁基础攻击力 Mac苹果电脑玩幻兽帕鲁 幻兽帕鲁加班加点

今天就跟大家聊聊《幻兽帕鲁》攻略&#xff1a;0基础入门及游戏基础操作。 如果想在苹果电脑玩《幻兽帕鲁》记得安装CrossOver哦。 以下纯干货&#xff1a; CrossOver正版安装包&#xff08;免费试用&#xff09;&#xff1a;https://souurl.cn/Y1gDao 一、基础操作 二、界面…
阅读更多...
加固平板电脑丨三防智能平板丨工业加固平板丨智能城市管理

加固平板电脑丨三防智能平板丨工业加固平板丨智能城市管理

随着智能城市的不断发展&#xff0c;人们对于城市管理的要求也在不断提高&#xff0c;这就需要高效、智能的城市管理平台来实现。而三防平板就是一款可以满足这一需求的智能设备。 三防平板是一种集防水、防尘、防摔于一体的智能平板电脑&#xff0c;它可以在复杂的环境下稳定运…
阅读更多...
鸿蒙（HarmonyOS）项目方舟框架（ArkUI）之ScrollBar组件

鸿蒙（HarmonyOS）项目方舟框架（ArkUI）之ScrollBar组件

鸿蒙&#xff08;HarmonyOS&#xff09;项目方舟框架&#xff08;ArkUI&#xff09;之ScrollBar组件 一、操作环境 操作系统: Windows 10 专业版、IDE:DevEco Studio 3.1、SDK:HarmonyOS 3.1 二、ScrollBar组件 鸿蒙&#xff08;HarmonyOS&#xff09;滚动条组件ScrollBar&…
阅读更多...
Unity BuffSystem buff系统

Unity BuffSystem buff系统

Unity BuffSystem buff系统 一、介绍二、buff系统架构三、架构讲解四、框架使用buff数据Json数据以及工具ShowTypeBuffTypeMountTypeBuffOverlapBuffShutDownTypeBuffCalculateType时间和层数这里也不过多说明了如何给生物添加buff 五、总结 一、介绍 现在基本做游戏都会需要些…
阅读更多...
pwn学习笔记（2）ret_2_text_or_shellcode

pwn学习笔记（2）ret_2_text_or_shellcode

pwn学习笔记&#xff08;2&#xff09; 1.三种常见的寄存器&#xff1a; ​ ax寄存器&#xff1a;通用寄存器&#xff0c;可用于存放多种数据 ​ bp寄存器&#xff1a;存放的是栈帧的栈底地址 ​ sp寄存器&#xff1a;存放的是栈顶的地址 2.栈帧与栈工作的简介&#xff1a…
阅读更多...
生态地板行业分析：营收入同比增长20%以上

生态地板行业分析：营收入同比增长20%以上

绿色建材是在全生命周期内可减少对天然资源消耗和减轻对生态环境影响&#xff0c;本质更安全、使用更便利&#xff0c;具有“节能、减排、安全、便利和可循环”特征的建材。低碳环保概念已经逐渐渗透到各个行业中&#xff0c;地板行业也不例外。尤其是在环保税法实施后&#xf…
阅读更多...
【RT-DETR有效改进】轻量级下采样方法ContextGuided（参数量下降700W，轻量又涨点）

【RT-DETR有效改进】轻量级下采样方法ContextGuided（参数量下降700W，轻量又涨点）

&#x1f451;欢迎大家订阅本专栏&#xff0c;一起学习RT-DETR&#x1f451; 一、本文介绍 本文给大家带来的是改进机制是一种替换Conv的模块Context Guided Block (CG block) &#xff0c;其是在CGNet论文中提出的一种模块&#xff0c;其基本原理是模拟人类视觉系统依赖上…
阅读更多...
人力资源智能化管理项目（day03:主页模块）

人力资源智能化管理项目（day03:主页模块）

学习源码可以看我的个人前端学习笔记 (github.com):qdxzw/humanResourceIntelligentManagementProject 觉得有帮助的同学&#xff0c;可以点心心支持一下哈 主页权限验证(permission.js) import router from /router import nprogress from nprogress // 进度条 import nprog…
阅读更多...
Django模板（二）

Django模板（二）

标签if 标签在渲染过程中提供使用逻辑的方法,比如:if和for 标签被 {% 和 %} 包围，如下所示： 由于在模板中，没有办法通过代码缩进判断代码块，所以控制标签都需要有结束的标签 if判断标签{% if %} {% endif %} ： # athlete_list 不为空 {% if athlete_list %}# 输出 ath…
阅读更多...
Spring + Tomcat项目中nacos配置中文乱码问题解决

Spring + Tomcat项目中nacos配置中文乱码问题解决

实际工作的时候碰到了nacos中文乱码的问题&#xff0c;一顿排查最终还是调源码解决了。下面为具体的源码流程&#xff0c;有碰到的可以参考下。 对于nacos配置来说&#xff0c;初始主要源码就在NacosConfigService类中。里面有初始化获取配置content以及设置对应监听器的操作。…
阅读更多...
原生JS使用PrintJs进行表格打印 -- 遇到的问题总结

原生JS使用PrintJs进行表格打印 -- 遇到的问题总结

需求1&#xff1a;表格自动分页之后&#xff0c;表头在每一页都需要显示 html中表头增加 thead 标签 css样式新增&#xff1a; thead {display: table-header-group; /* 这个属性使thead总是在新的page-break之后重新开始 */ }需求2&#xff1a;表格自动分页之后&#xff0c;…
阅读更多...
Springboot 整合 Elasticsearch（三）：使用RestHighLevelClient操作ES ①

Springboot 整合 Elasticsearch（三）：使用RestHighLevelClient操作ES ①

&#x1f4c1; 前情提要&#xff1a; Springboot 整合 Elasticsearch&#xff08;一&#xff09;&#xff1a;Linux下安装 Elasticsearch 8.x Springboot 整合 Elasticsearch&#xff08;二&#xff09;&#xff1a;使用HTTP请求来操作ES 目录 一、Springboot 整合 Elasticsea…
阅读更多...
c++设计模式之装饰器模式

c++设计模式之装饰器模式

作用 为现有类增加功能 案例说明 class Car { public:virtual void show()0; };class Bmw:public Car { public:void show(){cout<<"宝马汽车>>"<<endl;} };class Audi:public Car { public:void show(){cout<<"奥迪汽车>>&q…
阅读更多...
2023年12月 Python（三级）真题解析#中国电子学会#全国青少年软件编程等级考试

2023年12月 Python（三级）真题解析#中国电子学会#全国青少年软件编程等级考试

Python等级考试（1~6级）全部真题・点这里 一、单选题（共25题，共50分） 第1题 一个非零的二进制正整数，在其末尾添加两个“0”，则该新数将是原数的？（　） A：10倍 B：2倍 C：4倍 D：8倍 答案：C 二进制进位规则是逢二进一，因此末尾添加一个0，是扩大2倍，添加两个0…
阅读更多...
【Linux开发工具】yum命令详解

【Linux开发工具】yum命令详解

&#x1f4d9; 作者简介 &#xff1a;RO-BERRY &#x1f4d7; 学习方向&#xff1a;致力于C、C、数据结构、TCP/IP、数据库等等一系列知识 &#x1f4d2; 日后方向 : 偏向于CPP开发以及大数据方向&#xff0c;欢迎各位关注&#xff0c;谢谢各位的支持 目录 1.概念2.yum的配置信…
阅读更多...
Docker-Learn（二）保存、导入、使用Docker镜像

Docker-Learn（二）保存、导入、使用Docker镜像

1.保存镜像 根据上一节内容&#xff0c;将创建好镜像进行保存&#xff0c;需要退出当前的已经在运行的docer命令行中断里面&#xff0c;可以通过在终端里面输入指令exit或者按下键盘上的 ctrlD建退出&#xff1a; 回到自己的终端里面&#xff0c;输入指令&#xff1a; docker…
阅读更多...
学习VR全景拍摄，如何选择适合的VR全景设备？

学习VR全景拍摄，如何选择适合的VR全景设备？

随着VR全景技术的不断成熟和发展&#xff0c;VR全景已经成为摄影爱好者、地产行业、中介经纪人、广告、企业宣传等行业从业者们乐于尝试的新领域、新手段。 如何选择合适的VR全景设备成为了一个重要的问题。今天&#xff0c;和大家聊一聊&#xff0c;不同行业、人群和用途更适合…
阅读更多...
从Unity到Three.js（安装启动）

从Unity到Three.js（安装启动）

发现在3D数字孪生或模拟仿真方向&#xff0c;越来越多的公司倾向使用Web端程序&#xff0c;目前一直都是使用的Unity进行的Web程序开发&#xff0c;但是存在不少问题&#xff0c;比如内存释放、shader差异化、UI控件不支持复制或输入中文等。虽然大多数问题都可以找到解决方案&…
阅读更多...
最新文章

Copyright @ 2022~2023