要使任务和线程能安全,快速,可靠地停止下来,并不是一件容易的事情.Java没有提供任何机制来安全地终止线程.但是它提供了中断,这是一种协作机制,能够使一个线程终止另一个线程的当前工作
一,一种停止线程的协作机制----请求取消标记
设置一个"已请求取消"的标识,而任务将定期地查看这个标识.如果设置了这个标识,那么任务将提前结束.
但是可能会出现一个问题,因为queue是阻塞的,当队列为空的时候进行put操作,那么队列将会被阻塞-------任务将会永远看不到这个取消的标识,也就永远不会结束
public class Test {
public static void main(String[] args) throws InterruptedException {
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
Worker worker = new Worker(queue);
Thread thread = new Thread(worker);
thread.start();
for(int i=0; i<15; i++){
queue.put(i);
}
Thread.sleep(2000);
worker.cancel();
}
}
class Worker implements Runnable{
private boolean isCanceled;
private BlockingQueue<Integer> queue;
Worker(BlockingQueue<Integer> queue){
this.queue = queue;
}
@Override
public void run() {
while(!isCanceled){
try {
Integer elem = queue.take();
System.out.println(Thread.currentThread().getName()+" elem = "+ elem);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
public void cancel(){
isCanceled = true;
}
}
二,利用中断来中止线程和取消任务
1, 首先先说下Thread类的三个方法
1)public void interrupt()
中断线程。
2)public boolean isInterrupted()
测试线程是否已经中断。线程的 中断状态 不受该方法的影响。
线程中断被忽略，因为在中断时不处于活动状态的线程将由此返回 false 的方法反映出来。
如果该线程已经中断，则返回 true；否则返回 false。
3)public static boolean interrupted()
测试当前线程是否已经中断。线程的 中断状态 由该方法清除
如果当前线程已经中断，则返回 true；否则返回 false。
2,关于线程中断描述
- JVM不能保证阻塞方法检测到中断的速度,但在实际情况中响应速度还是非常快的
- 调用interrupt并不意味着立即停止目标线程正在进行的工作,而只是传递了请求终端的消息
- 通常,中断是实现取消的最合理方式
public class Test {
public static void main(String[] args) throws InterruptedException {
BlockingQueue<Integer> queue = new ArrayBlockingQueue<>(10);
Worker worker = new Worker(queue);
worker.start();
for(int i=0; i<15; i++){
queue.put(i);
}
Thread.sleep(2000);
worker.cancel();
}
}
class Worker extends Thread{
private boolean isCanceled;
private BlockingQueue<Integer> queue;
Worker(BlockingQueue<Integer> queue){
this.queue = queue;
}
@Override
public void run() {
while(!isCanceled){
try {
Integer elem = queue.take();
System.out.println(Thread.currentThread().getName()+" elem = "+ elem);
} catch (InterruptedException e) {
e.printStackTrace();
isCanceled = true;
}
}
}
public void cancel(){
interrupt();
}
}
三,处理不可中断的阻塞
在java库中,许多可阻塞的方法都是通过提前返回或者抛出InterruptedException来响应终端请求的,从而使开发人员更容易构建出能响应取消请求的任务.然而,并非所有的可阻塞方法或者阻塞机制都能响应中断
Java.io包中的同步Socket I/O
在服务器应用程序中,最常见的阻塞I/O形式就是对套接字进行读取和写入.虽然InputStream和OutputStream中的read和write等方法都不会响应终端,但通过关闭底层的套接字,可以使得由于执行read或write等方法而被阻塞的线程抛出一个SocketExceptionJava.io包中的同步I/O
当中断一个正在InterruptibleChannel上等待的线程时,将抛出ClosedByInterruptException并关闭链路.当关闭一个InterruptibleChannel时,将导致所有在链路操作上阻塞的线程都抛出AsyncchronousCloseException.Selector的同步I/O
如果一个线程在调用Selector.select方法时阻塞了,那么调用close或wakeup方法将使线程抛出ClosedSelectionException并提前返回获取某个锁
如果一个线程由于等待某个内置锁而阻塞,那么将无法响应中断,因为线程认为它肯定会获得锁,所以将不会理会中断请求.但是,在Lock类中提供了lockInterruptibly方法,该方法允许在等待一个锁的同时仍能够响应中断
参考:
<<java编发编程实战>>
