Java 多线程编程 - 任务的 cancel 方法、isCancelled 方法、isDone 方法

一、cancel 方法

booleancancel(booleanmayInterruptIfRunning);

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

二、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);

1. 调用future.cancel(true)，输出结果如下

请输入一个整数： 中断结果：true 12 任务被中断

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务执行 中断结果：false

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务 1 开始执行 中断结果：true 任务 1 执行完成

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务开始执行 中断结果：false

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务开始执行 任务被中断 中断结果：true 再次中断结果：false

2. 调用future.cancel(false)，输出结果如下

任务开始执行 任务被中断 中断结果：true 再次中断结果：false

小结

三、isCancelled 方法与 isDone 方法

1. isCancelled 方法用于检查任务是否被取消

booleanisCancelled();

2. 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);

1. 调用future.cancel(true)，输出结果如下

请输入一个整数： 任务是否被取消：false 任务是否完成：false 中断结果：true 任务是否被取消：true 任务是否完成：true 12 任务被中断

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务 1 开始执行 任务是否被取消：false 任务是否完成：false 中断结果：true 任务是否被取消：true 任务是否完成：true 任务 1 执行完成

2. 调用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);

1. 调用future.cancel(true)，输出结果如下

任务开始执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true

2. 调用future.cancel(false)，输出结果如下

任务开始执行 任务是否被取消：false 任务是否完成：true 中断结果：false 任务是否被取消：false 任务是否完成：true

小结