1.如何中断,什么时候中断
Thread的中断(interrupt)不是直接打断一个线程的执行,而是给这个线程加上一个中断的「标记」。比如一个线程的run方法里面,不停的打印这个线程被执行了多少次:
//thread的run方法里的内容:
while(true) {
// 死循环,等待被中断
System.out.println(getName() + getId() + "执行了" + ++i + "次");
}
要实现的效果是一秒后这个线程中断,不再打印:
//Interrupt test:
MyThread t = new MyThread("MyThread");
t.start();
Thread.sleep(1000);// 睡眠1000毫秒,这时候t告诉CPU不需要分配资源给它了,那么其他线程就抢占了CPU资源,这样这个线程里的其他动作就延缓执行了
t.interrupt();// 中断t线程
注意到上面的while(true)
,也就是说在t被中断前它会一直打印的。上面的这个例子执行起来会发现短短一瞬间打印了几百万次:
MyThread10执行了1520689次
MyThread10执行了1520690次
MyThread10执行了1520691次
...
但是1秒钟过去了,还是在打印。这是因为Thread.interrupt()只是在「礼貌地请求」中断,不是立刻执行中断。中断是一种协作机制。当一个线程中断另一个线程时,被中断的线程不一定要立即停止正在做的事情。
怎么处理中断请求呢,可以通过轮询Thread.isInterrupted() 来读取。当然也可以不理会中断请求。比如我们用Windows的时候应用程序卡了,我们点了右上角的红叉但程序还是不会立刻关掉,这就是在发送中断请求,但是一直没人处理。然后我们就打开任务管理器强制关闭这个应用程序了。
//把上面的while(true)改成下面这样轮询是否中断,就会在一秒后停止打印了
while(!isInterrupted()){...}
2.中断阻塞方法
对于interrupt(),今天白天在邮件里答复错了。。当时回答说wait()接收到interrupt请求也需要等待轮询isInterrupted()来检查是否需要从阻塞状态恢复,这是不对的,真正的情况是会立刻取消阻塞并抛出异常。
当另一个线程通过调用 Thread.interrupt() 中断一个线程时会发生两种情况
- 如果那个线程在执行一个低级可中断阻塞方法,例如 Thread.sleep()、 Thread.join() 或 Object.wait(),那么它将取消阻塞并抛出 InterruptedException。
- 否则, interrupt() 只是设置线程的中断状态。 在被中断线程中运行的代码以后可以轮询中断状态,看看它是否被请求停止正在做的事情。
INTERRUPTED
Thread.interrupted()会清除中断状态(interrupted status)。如果当前线程已经被中断了就返回true,否则返回false。换句话说,如果这个方法连续执行了两次,第二次就会返回false(除非执行第二次之前又中断了)。
REFERENCE:
[1]http://www.ibm.com/developerworks/cn/java/j-jtp05236.html