Java多线程学习之线程的取消与中断机制
Posted 三月烟雨飘摇的南方
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Java多线程学习之线程的取消与中断机制相关的知识,希望对你有一定的参考价值。
任务和线程的启动很容易。在大多数情况下我们都会让他们运行直到结束,或是让他们自行停止。但是,有时我们希望提前结束任务或是线程,可能是因为用户请求取消,或是线程在规定时间内没有结束,或是出现了一些问题迫使线程要提前结束。
1 public class PrimeGenerator implements Runnable { 2 private final List<BigInteger> primes = new ArrayList<>(); 3 // 标志变量,设置为volatile,保证可见性 4 private volatile boolean canceled = false; 5 @Override 6 public void run() { 7 BigInteger p = BigInteger.ONE; 8 // 依靠标志位判断是否结束线程 9 while(!canceled){ 10 p = p.nextProbablePrime(); 11 synchronized (this){ 12 primes.add(p); 13 } 14 } 15 } 16 // 取消 17 public void cancel(){canceled = true;} 18 //返回结果 19 public synchronized List<BigInteger> get(){ 20 return primes; 21 } 22 }
1 public List<BigInteger> aPrimes() throws InterruptedException { 2 PrimeGenerator generator = new PrimeGenerator(); 3 new Thread(generator).start(); 4 try{ 5 // 睡眠1秒 6 TimeUnit.SECONDS.sleep(1); 7 }finally { 8 // 1秒后取消 9 generator.cancel(); 10 } 11 return generator.get(); 12 }
在上述代码中,PrimeGenerator采用了简单的取消策略:客户代码通过canceled来请求取消,PrimeGenerator在每次执行搜索前首先检查是否存在取消请求,如果存在则退出。
1 // 不推荐的写法 2 public class BrokenPrimeProducer extends Thread { 3 // 阻塞队列 4 private final BlockingQueue<BigInteger> queue; 5 // 中断位 6 private volatile boolean canceled = false; 7 8 public BrokenPrimeProducer(BlockingQueue<BigInteger> queue){ 9 this.queue = queue; 10 } 11 12 @Override 13 public void run(){ 14 try { 15 BigInteger p = BigInteger.ONE; 16 while (!canceled) { 17 // PUT操作可能会被阻塞,将无法检查 canceled 是否变化,因而无法响应退出 18 queue.put(p = p.nextProbablePrime()); 19 } 20 }catch (InterruptedException ex){} 21 } 22 23 public void cancel(){ 24 canceled = true; 25 } 26 }
1 public class Thread{ 2 public void inturrept(){......} 3 public boolean isInterrupted(){......} 4 public static boolean interrupted(){......} 5 }
1 public class PrimeProducer extends Thread { 2 // 阻塞队列 3 private final BlockingQueue<BigInteger> queue; 4 5 public PrimeProducer(BlockingQueue<BigInteger> queue){ 6 this.queue = queue; 7 } 8 9 @Override 10 public void run(){ 11 try { 12 BigInteger p = BigInteger.ONE; 13 while (!Thread.currentThread().isInterrupted()) { 14 queue.put(p = p.nextProbablePrime()); 15 } 16 }catch (InterruptedException ex){ 17 // 允许退出线程 18 } 19 } 20 21 public void cancel(){ 22 // 中断 23 interrupt(); 24 } 25 }
中断是实现取消的最合理方式,在取消之外的其他操作中使用中断,都是不合理的。
4、中断策略
中断策略解释某个中断请求:当发现中断请求时,应该做哪些工作,以多快的速度来响应中断。任务一般不会在其自己拥有的线程中执行,而是在其他某个服务(比如说,在一个其他线程或是线程池)中执行。对于非线程所有者而言(例如,对线程池来说,任何线程池实现之外的代码),应该保存并传递中断状态,使得真正拥有线程的代码才能对中断做出响应。
比如说,如果你书写一个库函数,一般会抛出InterruptedException作为中断响应,而不会在库函数时候把中断异常捕获并进行提前处理,而导致调用者被屏蔽中断。因为你不清楚调用者想要对异常进行何种处理,比如说,是接收中断后立即停止任务还是进行相关处理并继续执行任务。中断的处理必须由该任务自己决定,而不是由其他线程决定。
1 try { 2 // dosomething(); 3 } catch (InterruptedException e) { 4 // 捕获异常后恢复中断位 5 Thread.currentThread().interrupt(); 6 e.printStackTrace(); 7 }
1 public interface Future<V> { 2 // 是否取消线程的执行 3 boolean cancel(boolean mayInterruptIfRunning); 4 // 线程是否被取消 5 boolean isCancelled(); 6 //线程是否执行完毕 7 boolean isDone();以上是关于Java多线程学习之线程的取消与中断机制的主要内容,如果未能解决你的问题,请参考以下文章