FutureTask的cancel方法真的能停止掉一个正在执行的异步任务吗

  1. ExecutorService executor = Executors.newSingleThreadExecutor();
  2. FutureTask<?> futureTask = new FutureTask<String>(new Callable<String>() {
  3. @Override
  4. public String call() throws Exception {
  5. for(int i=0;i<10000;i++){
  6. System.out.println(i);
  7. }
  8. return null;
  9. }
  10. });
  11. executor.execute(futureTask);
  12. System.out.println("futureTask start");
  13. try {
  14. Thread.sleep(10);
  15. } catch (InterruptedException e) {
  16. // TODO Auto-generated catch block
  17. e.printStackTrace();
  18. }
  19. futureTask.cancel(true);
  20. System.out.println("futureTask cancel");
  21. }

我们先来看看这个例子，发现最终执行结果是9999，即异步任务并没有被cancel而是一直执行完毕，这样看来这个cancel方法有点名不副实啊。

其实我们如果查看FutureTask的源码就会发现cancel只不过是调用了Thread的interrupt方法，而interrupt只能是停掉线程中有sleep,wait,join逻辑的线程，抛出一个InterruptException。这样看来FutureTask的cancel方法并不能停掉一切正在执行的异步任务。但是这里我们有一个妥协的做法就是在判断条件中加!Thread.currentThread().isInterrupted()这个判断即可

  1. ExecutorService executor = Executors.newSingleThreadExecutor();
  2. FutureTask<?> futureTask = new FutureTask<String>(new Callable<String>() {
  3. @Override
  4. public String call() throws Exception {
  5. for(int i=0;i<10000&&!Thread.currentThread().isInterrupted();i++){
  6. System.out.println(i);
  7. }
  8. return null;
  9. }
  10. });
  11. executor.execute(futureTask);
  12. System.out.println("futureTask start");
  13. try {
  14. Thread.sleep(10);
  15. } catch (InterruptedException e) {
  16. // TODO Auto-generated catch block
  17. e.printStackTrace();
  18. }
  19. futureTask.cancel(true);
  20. System.out.println("futureTask cancel");


最终这个就可以真正的结束异步任务。

  到这里我们可以发现Java中并没有可以真正中断线程的方法，早期的stop已经不推荐使用，而interrupt方法也需要代码片段中有sleep,wait,join这些方法的调用，否则不能停止线程，现在java推荐的方式就是将run方法执行完，这就需要我们在while循环中加一个标志来控制退出，不过我们不需要额外设置这个标志，只需要调用thread的isInterrupted（）方法判断，这样外界就可以调用该线程的isInterrupted方法来停止现在了，不用额外添加标志。

赞 (0)

相关推荐