目录一、什么是中断机制1、背景理解2、中断的本质二、中断的三大核心 API三、如何中断一个正在运行的线程1、使用 volatile 标志位实现中断2、使用 AtomicBoolean 实现中断3、使用 interrupt() 方法中断线程四、interrupt 与 isInterrupted 源码行为五、中断协商的案例分析1、活动线程被中断2、阻塞状态下被中断六、Thread.interrupted() 方法详解1、功能说明2、方法对比七、线程中断机制总结八、使用 interrupt 的实际应用场景取消长任务九、结语一、什么是中断机制1、背景理解在多线程环境中一个线程不应该被其他线程强制停止而是应当由线程自身决定何时终止。因此像Thread.stop()、Thread.suspend()、Thread.resume()这些“暴力”方法都已经被废弃。Java 提供了一种更安全的协作式停止机制中断Interrupt机制。2、中断的本质中断只是一种协商机制。Java 没有为中断提供任何新的语法或强制行为线程的停止完全依靠程序员自行检测中断标志位并做出响应。每个线程对象内部都有一个中断标志位该标志位为true表示线程被请求中断为false表示线程正常运行。调用thread.interrupt();仅仅是将目标线程的中断标志位置为true线程是否停止、如何处理必须由线程自己判断if(Thread.currentThread().isInterrupted()){// 根据业务场景决定如何优雅退出}比喻理解在餐厅中顾客线程在吸烟。服务员其他线程告诉他“这里不能抽烟”调用interrupt()但顾客是被告知要停下而不是被强行拖走。是否真的停止需要顾客自己“觉悟”主动检测并停止行为。二、中断的三大核心 API方法类型功能interrupt()实例方法向目标线程发送中断信号设置中断标志位为trueisInterrupted()实例方法判断当前线程是否被中断不清除标志位Thread.interrupted()静态方法检查当前线程是否被中断并清除中断标志位三、如何中断一个正在运行的线程1、使用 volatile 标志位实现中断importjava.util.concurrent.TimeUnit;publicclassInterruptDemo1{staticvolatilebooleanisStopfalse;publicstaticvoidmain(String[]args){Threadt1newThread(()-{while(true){if(isStop){System.out.println(Thread.currentThread().getName() 检测到 isStoptrue程序停止);break;}System.out.println(t1 --- hello volatile);}},t1);t1.start();try{TimeUnit.MILLISECONDS.sleep(20);}catch(InterruptedExceptione){e.printStackTrace();}newThread(()-isStoptrue,t2).start();}}2、使用 AtomicBoolean 实现中断importjava.util.concurrent.TimeUnit;importjava.util.concurrent.atomic.AtomicBoolean;publicclassInterruptDemo2{staticAtomicBooleanstopFlagnewAtomicBoolean(false);publicstaticvoidmain(String[]args){Threadt1newThread(()-{while(true){if(stopFlag.get()){System.out.println(Thread.currentThread().getName() 检测到 stopFlagtrue程序停止);break;}System.out.println(t1 --- hello atomicBoolean);}},t1);t1.start();try{TimeUnit.MILLISECONDS.sleep(20);}catch(InterruptedExceptione){e.printStackTrace();}newThread(()-stopFlag.set(true),t2).start();}}3、使用 interrupt() 方法中断线程publicclassInterruptDemo3{publicstaticvoidmain(String[]args){Threadt1newThread(()-{while(true){if(Thread.currentThread().isInterrupted()){System.out.println(Thread.currentThread().getName() isInterruptedtrue程序停止);break;}System.out.println(t1 --- hello interrupt api);}},t1);t1.start();System.out.println(t1 默认中断标志位t1.isInterrupted());try{Thread.sleep(20);}catch(InterruptedExceptione){e.printStackTrace();}newThread(t1::interrupt,t2).start();// t2 通知 t1 中断}}四、interrupt 与 isInterrupted 源码行为行为总结当线程处于活动状态时interrupt()仅将中断标志设为true线程继续正常运行。当线程处于阻塞状态如sleep()、wait()、join()时调用interrupt()会立即抛出InterruptedException同时清除中断标志位。五、中断协商的案例分析1、活动线程被中断publicclassInterruptDemo4{publicstaticvoidmain(String[]args){Threadt1newThread(()-{for(inti1;i300;i){System.out.println(-----: i);}System.out.println(t1 中断标志Thread.currentThread().isInterrupted());},t1);t1.start();System.out.println(t1 默认中断标志t1.isInterrupted());try{Thread.sleep(2);}catch(InterruptedExceptione){e.printStackTrace();}t1.interrupt();System.out.println(t1 调用 interrupt() 后标志t1.isInterrupted());}}2、阻塞状态下被中断publicclassInterruptDemo5{publicstaticvoidmain(String[]args){Threadt1newThread(()-{while(true){if(Thread.currentThread().isInterrupted()){System.out.println(检测到中断信号退出);break;}try{Thread.sleep(200);}catch(InterruptedExceptione){System.out.println(sleep 被中断重新标记状态);Thread.currentThread().interrupt();}}},t1);t1.start();try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}newThread(t1::interrupt,t2).start();}}在遇到阻塞中断例如sleep()、wait()、join()等时必须在catch块中再次调用Thread.currentThread().interrupt()否则中断标志会被清除为false线程无法感知到中断状态从而导致程序无法正常退出。六、Thread.interrupted() 方法详解1、功能说明publicclassInterruptDemo6{publicstaticvoidmain(String[]args){System.out.println(Thread.currentThread().getName() Thread.interrupted());System.out.println(Thread.currentThread().getName() Thread.interrupted());Thread.currentThread().interrupt();System.out.println(Thread.currentThread().getName() Thread.interrupted());System.out.println(Thread.currentThread().getName() Thread.interrupted());}}Thread.interrupted()会返回当前线程的中断状态并清除它。也就是说第一次为true后再次调用会变成false。2、方法对比方法是否静态是否清除标志检查哪个线程Thread.interrupted()✅ 是✅ 清除当前线程isInterrupted()❌ 否❌ 不清除被调用的线程七、线程中断机制总结interrupt()通知目标线程中断设置标志位true。isInterrupted()判断是否被中断不清除标志位。Thread.interrupted()检查并清除当前线程中断状态。 一句话总结中断不是立即停止而是“线程间的温柔协商”。interrupt()只负责通知线程自己决定何时退出。八、使用 interrupt 的实际应用场景取消长任务场景背景假设你有一个文件上传线程用户点击“取消上传”后系统希望安全中断上传操作而不强制终止线程。示例代码文件上传任务importjava.util.concurrent.TimeUnit;publicclassFileUploadDemo{publicstaticvoidmain(String[]args)throwsInterruptedException{ThreaduploadThreadnewThread(newFileUploader(),upload-thread);uploadThread.start();// 模拟用户在 3 秒后点击“取消上传”TimeUnit.SECONDS.sleep(3);System.out.println([main] 用户请求取消上传...);uploadThread.interrupt();}}classFileUploaderimplementsRunnable{Overridepublicvoidrun(){try{for(inti1;i10;i){// 每次上传一部分System.out.println([upload] 正在上传第 i 块数据...);TimeUnit.SECONDS.sleep(1);// 模拟耗时上传// 检查中断标志if(Thread.currentThread().isInterrupted()){System.out.println([upload] 检测到取消请求正在清理资源...);cleanup();break;}}System.out.println([upload] 上传线程安全结束。);}catch(InterruptedExceptione){// 响应 sleep 阻塞中断System.out.println([upload] 上传过程中被中断正在清理资源...);cleanup();Thread.currentThread().interrupt();// 重设标志方便外层检测}}privatevoidcleanup(){System.out.println([upload] 关闭文件流、删除临时文件...);}}输出结果示例总结通过interrupt()通知线程取消线程内部通过检测中断状态优雅地停止任务资源清理逻辑保证安全退出这种设计广泛用于文件下载/上传网络请求取消批量任务停止异步任务撤销等。九、结语Java 的中断机制是多线程协作的“绅士协议”。它不粗暴、不强制而是让线程之间可以安全、可控地终止任务。 记住一句话中断不是 stop是一种“温和的退出”。