news 2026/6/10 1:06:34

Java 多线程编程 - 线程池任务终止分析（线程池任务终止、中断的本质、检查中断）

作者头像

张小明

前端开发工程师

1.2k 24
文章封面图
Java 多线程编程 - 线程池任务终止分析（线程池任务终止、中断的本质、检查中断）

一、线程池任务终止

  1. shutdown()：等当前任务完成，然后停止
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{try{System.out.println("任务开始执行");Thread.sleep(5*1000);System.out.println("任务执行完成");}catch(InterruptedExceptione){System.out.println("任务被中断");}},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}scheduler.shutdown();
# 输出结果 任务开始执行 任务执行完成
  1. cancel(true) + shutdown()：立即中断当前任务，然后停止
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{try{System.out.println("任务开始执行");Thread.sleep(5*1000);System.out.println("任务执行完成");}catch(InterruptedExceptione){System.out.println("任务被中断");}},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}future.cancel(true);scheduler.shutdown();
# 输出结果 任务开始执行 任务被中断
  1. shutdownNow()：立即中断所有任务，然后停止
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{try{System.out.println("任务开始执行");Thread.sleep(5*1000);System.out.println("任务执行完成");}catch(InterruptedExceptione){System.out.println("任务被中断");}},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}scheduler.shutdownNow();
# 输出结果 任务开始执行 任务被中断

二、中断的本质

  1. Java 中的中断机制是协作式的，而不是强制性的

  2. 上述案例中的中断是通过触发Thread.sleep()的 InterruptedException 来实现的

  3. 中断只是设置标志位，并不能强制打断任务，如下例

ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{try{System.out.println("任务开始执行");ServerSocketserverSocket=newServerSocket(9999);serverSocket.accept();System.out.println("任务执行完成");}catch(IOExceptione){e.printStackTrace();}},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}future.cancel(true);scheduler.shutdown();
  1. Thread.sleep()在抛出 InterruptedException 时会自动清除中断标志位
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{try{System.out.println("任务开始执行");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());Thread.sleep(5*1000);System.out.println("任务执行完成");}catch(InterruptedExceptione){System.out.println("任务被中断");}finally{System.out.println("中断标志位："+Thread.currentThread().isInterrupted());}},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}future.cancel(true);scheduler.shutdown();
# 输出结果 任务开始执行 中断标志位：false 任务被中断 中断标志位：false

三、检查中断

  1. shutdown()：等当前任务完成，然后停止，中断标志位没有变化
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{System.out.println("任务开始执行");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());Scannerscanner=newScanner(System.in);System.out.print("请输入一个整数：");intnum=scanner.nextInt();System.out.println("任务执行完成");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}scheduler.shutdown();
# 输出结果 任务开始执行 中断标志位：false 请输入一个整数：12 任务执行完成 中断标志位：false
  1. cancel(true) + shutdown()：立即中断当前任务，中断标志位会被设置为 true，然后停止
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{System.out.println("任务开始执行");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());Scannerscanner=newScanner(System.in);System.out.print("请输入一个整数：");intnum=scanner.nextInt();System.out.println("任务执行完成");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}future.cancel(true);scheduler.shutdown();
# 输出结果 任务开始执行 中断标志位：false 请输入一个整数：12 任务执行完成 中断标志位：true
  1. shutdownNow()：立即中断所有任务，中断标志位会被设置为 true，然后停止
ScheduledExecutorServicescheduler=Executors.newScheduledThreadPool(1);// 启动任务，初始延迟 0 秒，每次执行完后延迟 1 秒再执行下一次ScheduledFuture<?>future=scheduler.scheduleWithFixedDelay(()->{System.out.println("任务开始执行");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());Scannerscanner=newScanner(System.in);System.out.print("请输入一个整数：");intnum=scanner.nextInt();System.out.println("任务执行完成");System.out.println("中断标志位："+Thread.currentThread().isInterrupted());},0,1,TimeUnit.SECONDS);try{Thread.sleep(2*1000);}catch(InterruptedExceptione){e.printStackTrace();}scheduler.shutdownNow();
# 输出结果 任务开始执行 中断标志位：false 请输入一个整数：12 任务执行完成 中断标志位：true
版权声明: 本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：809451989@qq.com进行投诉反馈，一经查实，立即删除！
网站建设 2026/6/5 20:45:42

FaceFusion人脸替换在广告创意中的应用场景

FaceFusion人脸替换在广告创意中的应用场景 在一条跨国品牌的电视广告中&#xff0c;中国观众看到的是由本地明星代言的产品介绍&#xff0c;而法国观众看到的却是另一位面孔熟悉的本土代言人——但两段视频的动作、场景、语调几乎完全一致。这并非来自不同拍摄团队的精心复刻&…

作者头像 李华
网站建设 2026/6/5 21:31:12

FaceFusion能否处理低质量监控画面？去噪增强双加持

FaceFusion能否处理低质量监控画面&#xff1f;去噪增强双加持在城市安防系统的日常运行中&#xff0c;一个令人头疼的问题反复浮现&#xff1a;明明摄像头拍到了嫌疑人&#xff0c;但画面模糊、噪点多、分辨率极低&#xff0c;人脸几乎无法辨认。这种情况下&#xff0c;传统人…

作者头像 李华
网站建设 2026/6/7 6:50:24

FaceFusion能否处理红外夜视画面？低光环境适配

FaceFusion能否处理红外夜视画面&#xff1f;低光环境适配在城市安防系统中&#xff0c;一个常见的尴尬场景是&#xff1a;监控摄像头在夜间自动切换至红外模式后&#xff0c;原本精准的人脸识别瞬间失效——算法要么完全漏检人脸&#xff0c;要么将热成像中的“发亮额头”误判…

作者头像 李华
网站建设 2026/6/9 4:53:01

FaceFusion镜像搭配大模型Token服务，开启AI创作新时代

FaceFusion镜像搭配大模型Token服务&#xff0c;开启AI创作新时代 在短视频与虚拟内容爆发式增长的今天&#xff0c;创作者对“以假乱真”的视觉效果需求日益高涨。无论是为老电影修复演员形象、让历史人物“开口说话”&#xff0c;还是打造个性化的数字分身&#xff0c;人脸替…

作者头像 李华
网站建设 2026/6/9 3:12:32

FaceFusion在教育领域的创新应用设想

FaceFusion在教育领域的创新应用设想 你有没有想过&#xff0c;一节由“本地化数字教师”主讲的英语课&#xff0c;虽然授课内容来自千里之外的名校教授&#xff0c;但站在屏幕前的老师却长着一张符合学生文化背景的脸&#xff1f;他的表情自然、口型同步&#xff0c;甚至能根据…

作者头像 李华
网站建设 2026/6/7 12:30:12

FaceFusion可用于教育场景？比如历史人物重现课堂

FaceFusion 能否让历史人物“走进”课堂&#xff1f;在一所普通中学的历史课上&#xff0c;讲台前的屏幕突然亮起。画面中&#xff0c;一位身着清代官服、目光坚毅的男子缓缓开口&#xff1a;“吾乃林则徐。道光十九年&#xff0c;我在虎门销烟&#xff0c;誓与鸦片共存亡……”…

作者头像 李华