大家好,我是鹏磊。
Thread Runable run
方法 return 结束执行。1 需要线程退出的常见场景
任务执行完成,或异常终止,任务认为无需再占用线程。 线程池根据当前任务执行情况,伸缩线程池。当任务执行较少时,退出空闲的线程。 服务或进程在关闭阶段,例如滚动发布时,需要退出线程、关闭线程池、关闭进程。 定时任务、周期任务需要终止执行时,需要退出当前线程。或者退出当前任务的执行。
2 优雅关闭 or 强行关闭
3 其他语言和 Java 语言退出线程的方式
pthread_cancel
通知线程关闭等优雅退出方式。Thread.stop()
强制中断线程的注释中, JDK 这样解释Thread.stop()
这种方法本身就是不安全的,Stop 一个线程会随之解锁这个线程所持有的监视器(可以理解为锁),如果受这些监视器(锁)保护的临界对象处在不一致状态,则其他线程可能会看到这些对象处于不一致状态,那么将导致未知的行为。对Thread.Stop()
的调用应该被简单的代码代替,例如 修改一个变量,目标线程定期检查这个变量,有序从 run 方法 return 出来。如果目标线程在一个条件变量上 wait,则其他线程应该使用 interrupt 方法中断目标线程。
4 优雅退出线程
业务字段标记
while(config.isTaskEnable()) {
//从配置中心获取任务是否要终止
//循环执行业务逻辑。直到执行完成退出,或者被终止。
}
Thread.interrupt()
JDK 中提到了如果目标线程没有处于运行态,而是处于阻塞状态,自然无法检查退出的状态标记,如何通知这个线程退出呢?
恰好目标线程在调用。 Object.wait()
,object.join ()
,Object.sleep()
等方法时,目标线程的中断位标记被清除,同时目标线程会立即从 sleep、wait 等调用中恢复,并且被抛出InterruptException
。如果目标线程在 IO 操作中被阻塞,例如 io.channels.InterruptibleChannel
,Channel 将被关闭,线程的中断位被设置,同时目标线程收到java.nio.channels.ClosedByInterruptException
。如果目标线程被阻塞在 java.nio.channels.Selector
,线程中断状态被设置,然后目标线程立即从 select 中返回非零值。如果其他条件都不成立,该线程中断位会被设置。
Thread.isInterrupted
方法查看当前是否处于中断位?那为什么目标线程阻塞在 Object.wait()
,Sleep()
方法时,抛出了 interruptException
,会取消标记呢?实际上 interrupt 操作执行两件事,1)设置中断位标记 2)通过 unpark 唤醒目标线程(park 和 unpark 分别可以阻塞线程和唤醒线程)。推荐的中断响应策略
目标线程的任务在 InterruptedException
异常处理中,要主动回收资源,打印日志,退出任务执行。目标线程如果没有阻塞操作,例如 sleep、wait。可以通过 Thread.isInterrupted()
,查看当前中断位状态,如果被中断了,则采取以上第一步操作。
抛出 InterruptedException
给上层,由上层代码处理。调用 Thread.interrupt()
。重新设置中断位标记 (自己中断自己)。由上游代码在本层方法返回后,检查中断位标记,进行中断处理。
InterruptedException
,让上游感知到下游调用链中存在阻塞,让上游对中断异常进行处理。InterruptedException
后,忽略异常,不执行任何操作,继续执行业务逻辑。for (int i = 0; i < cnt; i++) {
try {
//执行业务逻辑
Thread.sleep(10000);
} catch (InterruptedException e) {
System.out.println("被中断");
}
System.out.println("子线程执行中");
}
while(true){
callChildMethod();//调用下游方法,但是下游吞掉了中断
if (Thread.currentThread().isInterrupted()) {
//回收资源,退出线程
}
}
Thread.interrupted
方法会返回当前中断标记,并且取消中断位。如果只查询中断位,不想清理,可以使用 Thread.isInterrupted()
。5 总结
不推荐强制销毁线程,会导致资源无法被释放,进行中请求无法正常处理完,导致业务数据处于不可知的状态。 Java 推荐优雅退出线程。 业务层可以使用字段标记,定期检查是否需要退出任务。 Thread.interrupt
中断目标线程、isInterrupted
查询中断位标记。使用 Thread.interrupt
处理中断也可以优雅退出,但需要上下层堆栈都要关注中断,不得吞掉中断。