JDK并发包温故知新系列(三)—— 线程的中断

须要进行线程中断的场景

  • 不少线程的运行模式是死循环,好比在生产者/消费者模式中,消费者主体就是一个死循环,它不停的从队列中接受任务,执行任务,在中止程序时,咱们须要一种"优雅"的方法以关闭该线程。
  • 在一些用户启动的任务中,线程是用户启动的,好比手动启动批次任务,在任务执行过程当中,用户可能会但愿取消该任务。
  • 在一些场景中,好比从第三方服务器查询一个结果,咱们但愿在限定的时间内获得结果,若是得不到,咱们会但愿取消该任务。
  • 有时,咱们会启动多个线程作同一件事,好比相似抢火车票,咱们可能会让多个好友帮忙从多个渠道买火车票,只要有一个渠道买到了,咱们会通知取消其余渠道。

涉及的线程方法(Thread对象方法)

  • public boolean isInterrupted() 判断线程中断标志位是否为true
  • public void interrupt() 设置线程中断标志位为true,但对于线程不一样的状态,不必定能设置成功。
  • public static boolean interrupted() 返回线程中断标志位,并清空。

线程对中断的反应

分几种状况:服务器

RUNNABLE状态-线程调用了start()方法,处于等待系统调度或在运行中

这种状况下只设置中断标志位。多线程

WAITING/TIMED_WAITING-等待状态

当调用以下方法时进入等待状态,包括的方法有:线程

WATING:调用了锁资源的wait方法,或调用了join方法。code

TIMED_WAITING:wait(long timeout),sleep(long millis),join(long millis)。(wait与sleep的区别:是否释放锁)。对象

抛出InterruptedException异常而且线程中断标志位被清空,针对此通常通常是交由上级处理,若但愿线程中断,在catch里面执行清理工做或重设线程标志位。队列

BLOCKED-线程处于锁等待队列,试图进入同步块

只设置标志位。资源

NEW/TERMINATED-线程结束了或还未调用start()方法

不会有任何效果。同步

注意

不是说调用了interrupt()方法,线程就终止了,须要线程实现者经过代码实现,以下:it

while (!Thread.currentThread().isInterrupted()) {
//清理逻辑
 }
相关文章
相关标签/搜索