如何停止一个线程池?

Java 并发工具包中java.util.concurrent.ExecutorService 接口定义了线程池任务提交、获取线程池状态、线程池停止的方法等。

JDK 1.8 中,线程池的停止一般使用shutdown()、shutdownNow()、shutdown() + awaitTermination(long timeout, TimeUnit unit) 方法。

1、shutdown() 方法源码中解释

 * Initiates an orderly shutdown in which previously submitted * tasks are executed, but no new tasks will be accepted. * Invocation has no additional effect if already shut down.
  • 有序关闭,已提交任务继续执行
  • 不接受新任务

2、shutdownNow() 方法源码中解释

 * Attempts to stop all actively executing tasks, halts the * processing of waiting tasks, and returns a list of the tasks * that were awaiting execution.
  • 尝试停止所有正在执行的任务
  • 停止等待执行的任务,并返回等待执行的任务列表

3、awaitTermination(long timeout, TimeUnit unit) 方法源码中解释

 * Blocks until all tasks have completed execution after a shutdown * request, or the timeout occurs, or the current thread is * interrupted, whichever happens first. * * @param timeout the maximum time to wait * @param unit the time unit of the timeout argument * @return {@code true} if this executor terminated and * {@code false} if the timeout elapsed before termination * @throws InterruptedException if interrupted while waiting
  • 收到关闭请求后,所有任务执行完成、超时、线程被打断,阻塞直到三种情况任意一种发生
  • 参数可以设置超时时间与超时单位
  • 线程池关闭返回 true;超过设置时间未关闭,返回 false

实践:

1、使用Executors.newFixedThreadPool(int nThreads) 创建固定大小线程池,测试shutdown() 方法

package constxiong.concurrency.a013;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * 测试固定数量线程池 shutdown() 方法 * @author ConstXiong */public class TestFixedThreadPoolShutdown {public static void main(String[] args) {//创建固定 3 个线程的线程池ExecutorService threadPool = Executors.newFixedThreadPool(3);//向线程池提交 10 个任务for (int i = 1; i <= 10; i++) {final int index = i;threadPool.submit(() -> {System.out.println("正在执行任务 " + index);//休眠 3 秒try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}});}//休眠 4 秒try {Thread.sleep(4000);} catch (InterruptedException e) {e.printStackTrace();}//关闭线程池threadPool.shutdown();}}

打印结果如下,可以看出,主线程向线程池提交了 10 个任务,休眠 4秒后关闭线程池,线程池把 10 个任务都执行完成后关闭了。

正在执行任务 1正在执行任务 3正在执行任务 2正在执行任务 4正在执行任务 6正在执行任务 5正在执行任务 8正在执行任务 9正在执行任务 7正在执行任务 10

2、使用Executors.newFixedThreadPool(int nThreads) 创建固定大小线程池,测试shutdownNow() 方法

package constxiong.concurrency.a013;import java.util.List;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * 测试固定数量线程池 shutdownNow() 方法 * @author ConstXiong */public class TestFixedThreadPoolShutdownNow {public static void main(String[] args) {//创建固定 3 个线程的线程池ExecutorService threadPool = Executors.newFixedThreadPool(3);//向线程池提交 10 个任务for (int i = 1; i <= 10; i++) {final int index = i;threadPool.submit(() -> {System.out.println("正在执行任务 " + index);//休眠 3 秒try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}});}//休眠 4 秒try {Thread.sleep(4000);} catch (InterruptedException e) {e.printStackTrace();}//关闭线程池List<Runnable> tasks = threadPool.shutdownNow();System.out.println("剩余 " + tasks.size() + " 个任务未执行");}}

打印结果如下,可以看出,主线程向线程池提交了 10 个任务,休眠 4秒后关闭线程池,线程池执行了 6 个任务,抛出异常,打印返回的剩余未执行的任务个数。

正在执行任务 1正在执行任务 2正在执行任务 3正在执行任务 4正在执行任务 6正在执行任务 5剩余 4 个任务未执行java.lang.InterruptedException: sleep interruptedat java.lang.Thread.sleep(Native Method)at constxiong.concurrency.a013.TestFixedThreadPoolShutdownNow.lambda$0(TestFixedThreadPoolShutdownNow.java:24)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:748)java.lang.InterruptedException: sleep interruptedat java.lang.Thread.sleep(Native Method)at constxiong.concurrency.a013.TestFixedThreadPoolShutdownNow.lambda$0(TestFixedThreadPoolShutdownNow.java:24)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:748)java.lang.InterruptedException: sleep interruptedat java.lang.Thread.sleep(Native Method)at constxiong.concurrency.a013.TestFixedThreadPoolShutdownNow.lambda$0(TestFixedThreadPoolShutdownNow.java:24)at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)at java.util.concurrent.FutureTask.run(FutureTask.java:266)at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)at java.lang.Thread.run(Thread.java:748)

3、Executors.newFixedThreadPool(int nThreads) 创建固定大小线程池,测试awaitTermination(long timeout, TimeUnit unit) 方法

package constxiong.concurrency.a013;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.TimeUnit;/** * 测试固定数量线程池 shutdownNow() 方法 * @author ConstXiong */public class TestFixedThreadPoolAwaitTermination {public static void main(String[] args) {//创建固定 3 个线程的线程池ExecutorService threadPool = Executors.newFixedThreadPool(3);//向线程池提交 10 个任务for (int i = 1; i <= 10; i++) {final int index = i;threadPool.submit(() -> {System.out.println("正在执行任务 " + index);//休眠 3 秒try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}});}//关闭线程池,设置等待超时时间 3 秒System.out.println("设置线程池关闭,等待 3 秒...");threadPool.shutdown();try {boolean isTermination = threadPool.awaitTermination(3, TimeUnit.SECONDS);System.out.println(isTermination ? "线程池已停止" : "线程池未停止");} catch (InterruptedException e) {e.printStackTrace();}//再等待超时时间 20 秒System.out.println("再等待 20 秒...");try {boolean isTermination = threadPool.awaitTermination(20, TimeUnit.SECONDS);System.out.println(isTermination ? "线程池已停止" : "线程池未停止");} catch (InterruptedException e) {e.printStackTrace();}}}

打印结果如下,可以看出,主线程向线程池提交了 10 个任务,申请关闭线程池 3秒超时,3 秒后线程池并未成功关闭;再获取线程池关闭状态20秒超时,线程池成功关闭。

正在执行任务 1正在执行任务 3正在执行任务 2设置线程池关闭,等待 3 秒...线程池未停止正在执行任务 4正在执行任务 6再等待 20 秒...正在执行任务 5正在执行任务 7正在执行任务 9正在执行任务 8正在执行任务 10线程池已停止

总结:

  1. 调用 shutdown() 和shutdownNow() 方法关闭线程池,线程池都无法接收新的任务
  2. shutdown() 方法会继续执行正在执行未完成的任务;shutdownNow() 方法会尝试停止所有正在执行的任务
  3. shutdown() 方法没有返回值;shutdownNow() 方法返回等待执行的任务列表
  4. awaitTermination(long timeout, TimeUnit unit) 方法可以获取线程池是否已经关闭,需要配合shutdown() 使用
  5. shutdownNow() 不一定能够立马结束线程池,该方法会尝试停止所有正在执行的任务,通过调用 Thread.interrupt() 方法来实现的,如果线程中没有 sleep() 、wait()、Condition、定时锁等应用, interrupt() 方法是无法中断当前的线程的。

给TA打赏
共{{data.count}}人
人已打赏
Java

如何避免死锁?

2020-7-31 0:20:00

Java

为什么要用并发编程?

2020-7-31 0:23:20

本站所发布的一切源码、模板、应用等文章仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版,购买注册,得到更好的正版服务。如有侵权。本站内容适用于DMCA政策。若您的权利被侵害,请与我们联系处理,站长 QQ: 84087680 或 点击右侧 私信:盾给网 反馈,我们将尽快处理。
⚠️
本站所发布的一切源码、模板、应用等文章仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版,购买注册,得到更好的正版服务。如有侵权。本站内容适用于DMCA政策
若您的权利被侵害,请与我们联系处理,站长 QQ: 84087680 或 点击右侧 私信:盾给网 反馈,我们将尽快处理。
0 条回复 A文章作者 M管理员
    暂无讨论,说说你的看法吧
个人中心
购物车
优惠劵
今日签到
有新私信 私信列表
搜索