一、cancel 方法
booleancancel(booleanmayInterruptIfRunning);
| 参数值 | 说明 |
|---|
| true | 如果任务正在执行，中断任务 |
| false | 如果任务正在执行，不会中断任务；如果任务还未开始，中断任务 |
| 返回值 | 说明 |
|---|
| true | 任务取消成功 |
| false | 任务取消失败，任务已经完成、已经被取消等 |
二、cancel 方法实例
1、任务执行中进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{Scannerscanner=newScanner(System.in);while(true){System.out.println("请输入一个整数：");intnum=scanner.nextInt();if(Thread.currentThread().isInterrupted()){System.out.println("任务被中断");break;}System.out.println("输入的整数是："+num);}});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleanresult=【在这里中断任务】System.out.println("中断结果："+result);
- 调用
future.cancel(true)，输出结果如下
请输入一个整数： 中断结果：true 12 任务被中断
- 调用
future.cancel(false)，输出结果如下
请输入一个整数： 中断结果：true 12 输入的整数是：12 请输入一个整数：
2、任务执行完成后进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{System.out.println("任务执行");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleanresult=【在这里中断任务】System.out.println("中断结果："+result);
- 调用
future.cancel(true)，输出结果如下
任务执行 中断结果：false
- 调用
future.cancel(false)，输出结果如下
任务执行 中断结果：false
3、任务执行前进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();executorService.submit(()->{System.out.println("任务 1 开始执行");try{Thread.sleep(5*1000);}catch(InterruptedExceptione){e.printStackTrace();}System.out.println("任务 1 执行完成");});Future<?>future=executorService.submit(()->{System.out.println("任务 2 开始执行");System.out.println("任务 2 执行完成");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleanresult=【在这里中断任务】System.out.println("中断结果："+result);
- 调用
future.cancel(true)，输出结果如下
任务 1 开始执行 中断结果：true 任务 1 执行完成
- 调用
future.cancel(false)，输出结果如下
任务 1 开始执行 中断结果：true 任务 1 执行完成
4、任务异常后进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{System.out.println("任务开始执行");inta=10/0;System.out.println("任务执行完成");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleanresult=【在这里中断任务】System.out.println("中断结果："+result);
- 调用
future.cancel(true)，输出结果如下
任务开始执行 中断结果：false
- 调用
future.cancel(false)，输出结果如下
任务开始执行 中断结果：false
5、任务中断后进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{System.out.println("任务开始执行");try{Thread.sleep(5*1000);}catch(InterruptedExceptione){System.out.println("任务被中断");thrownewRuntimeException(e);}System.out.println("任务执行完成");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleanresult=future.cancel(true);System.out.println("中断结果："+result);booleanresult2=【在这里再次中断任务】System.out.println("再次中断结果："+result2);
- 调用
future.cancel(true)，输出结果如下
任务开始执行 任务被中断 中断结果：true 再次中断结果：false
- 调用
future.cancel(false)，输出结果如下
任务开始执行 任务被中断 中断结果：true 再次中断结果：false
小结
| - | future.cancel(true) | future.cancel(false) |
|---|
| 任务执行前 | true | true |
| 任务执行中 | true | true |
| 任务执行完成后 | false | false |
| 任务异常后 | false | false |
| 任务中断后 | false | false |
三、isCancelled 方法与 isDone 方法
- isCancelled 方法用于检查任务是否被取消
booleanisCancelled();
- isDone 方法用于检查任务是否完成
booleanisDone();
四、isCancelled 方法与 isDone 方法实例
1、任务执行中 + 任务执行中进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{Scannerscanner=newScanner(System.in);while(true){System.out.println("请输入一个整数：");intnum=scanner.nextInt();if(Thread.currentThread().isInterrupted()){System.out.println("任务被中断");break;}System.out.println("输入的整数是："+num);}});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleancancelled=future.isCancelled();System.out.println("任务是否被取消："+cancelled);booleandone=future.isDone();System.out.println("任务是否完成："+done);booleanresult=【在这里中断任务】System.out.println("中断结果："+result);booleancancelled2=future.isCancelled();System.out.println("任务是否被取消："+cancelled2);booleandone2=future.isDone();System.out.println("任务是否完成："+done2);
- 调用
future.cancel(true)，输出结果如下
请输入一个整数： 任务是否被取消：false 任务是否完成：false 中断结果：true 任务是否被取消：true 任务是否完成：true 12 任务被中断
- 调用
future.cancel(false)，输出结果如下
请输入一个整数： 任务是否被取消：false 任务是否完成：false 中断结果：true 任务是否被取消：true 任务是否完成：true 12 输入的整数是：12 请输入一个整数：
2、任务执行完成后 + 任务执行完成后进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{System.out.println("任务执行");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleancancelled=future.isCancelled();System.out.println("任务是否被取消："+cancelled);booleandone=future.isDone();System.out.println("任务是否完成："+done);booleanresult=【在这里中断任务】System.out.println("中断结果："+result);booleancancelled2=future.isCancelled();System.out.println("任务是否被取消："+cancelled2);booleandone2=future.isDone();System.out.println("任务是否完成："+done2);
- 调用
future.cancel(true)，输出结果如下
任务执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true
- 调用
future.cancel(false)，输出结果如下
任务执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true
3、任务执行前 + 任务执行前进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();executorService.submit(()->{System.out.println("任务 1 开始执行");try{Thread.sleep(5*1000);}catch(InterruptedExceptione){e.printStackTrace();}System.out.println("任务 1 执行完成");});Future<?>future=executorService.submit(()->{System.out.println("任务 2 开始执行");System.out.println("任务 2 执行完成");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleancancelled=future.isCancelled();System.out.println("任务是否被取消："+cancelled);booleandone=future.isDone();System.out.println("任务是否完成："+done);booleanresult=【在这里中断任务】System.out.println("中断结果："+result);booleancancelled2=future.isCancelled();System.out.println("任务是否被取消："+cancelled2);booleandone2=future.isDone();System.out.println("任务是否完成："+done2);
- 调用
future.cancel(true)，输出结果如下
任务 1 开始执行 任务是否被取消：false 任务是否完成：false 中断结果：true 任务是否被取消：true 任务是否完成：true 任务 1 执行完成
- 调用
future.cancel(false)，输出结果如下
任务 1 开始执行 任务是否被取消：false 任务是否完成：false 中断结果：true 任务是否被取消：true 任务是否完成：true 任务 1 执行完成
4、任务异常后 + 任务异常后进行中断
ExecutorServiceexecutorService=Executors.newSingleThreadExecutor();Future<?>future=executorService.submit(()->{System.out.println("任务开始执行");inta=10/0;System.out.println("任务执行完成");});try{Thread.sleep(1000);}catch(InterruptedExceptione){e.printStackTrace();}booleancancelled=future.isCancelled();System.out.println("任务是否被取消："+cancelled);booleandone=future.isDone();System.out.println("任务是否完成："+done);booleanresult=【在这里中断任务】System.out.println("中断结果："+result);booleancancelled2=future.isCancelled();System.out.println("任务是否被取消："+cancelled2);booleandone2=future.isDone();System.out.println("任务是否完成："+done2);
- 调用
future.cancel(true)，输出结果如下
任务开始执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true
- 调用
future.cancel(false)，输出结果如下
任务开始执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true
小结
| - | isCancelled() | isDone() |
|---|
| 任务执行前 | false | false |
| 任务执行中 | false | false |
| 任务执行完成后 | false | true |
| 任务异常后 | false | true |
| 任务执行前进行中断 | true | true |
| 任务执行中进行中断 | true | true |
| 任务执行完成后进行中断 | false | true |
| 任务异常后进行中断 | false | true |
