Java 多线程编程 - 任务的 cancel 方法、isCancelled 方法、isDone 方法-洪萨配资

一、cancel 方法

booleancancel(booleanmayInterruptIfRunning);

cancel 方法用于取消异步任务的执行

参数值	说明
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