Java并发编程高级篇(八)：在执行器中取消任务

前面我们已经学习如何把任务发送给执行器去执行，但是当我们想要取消一个已经发送给执行器的任务该怎么办呢。可以使用Future对象的cancel()方法。

首先我们创建一个任务线程类，实现Callable接口(当然你使用Runnable接口是一样的)。任务一直循环打印"This is running."，并每次休眠100ms来模拟任务执行过程。

import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;

/**
 * Created by hadoop on 2016/11/3.
 */
public class Task implements Callable<String> {
    @Override
    public String call() throws Exception {
        while (true) {
            System.out.println("Task is running.");
            TimeUnit.MILLISECONDS.sleep(100);
        }
    }
}

接下来创建主线程类。在这里我们使用Executors.newCachedThreadPool()来创建线程执行器。提交任务后休眠1s，并结束任务。

• Future.cancel(boolean mayInterruptIfRunning)：true意味着已经开始执行的任务可以被中断，false则已经运行的任务会一直运行完毕，而不会被终止。
• Future.isCancelled()：返回任务是否被成功取消。

import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * Created by hadoop on 2016/11/3.
 *
 * 想取消执行其中的任务，需要调用Future接口的cancel(boolean)方法。
 *
 * 1. 如果任务已经被取消，或者因为某种原因不能被取消，那么这个方法返回false，并且任务取消失败。
 * 2. 如如任务还没有开始执行那么任务会被直接取消。
 * 3. 传递true参数，任务无论是否开始执行都将被取消。传递false参数，如果任务已经开始执行那么无法取消。
 *
 */
public class Main {
    public static void main(String[] args) throws InterruptedException {
        ThreadPoolExecutor executor = (ThreadPoolExecutor)Executors.newCachedThreadPool();

        Task task = new Task();

        Future<String> future = executor.submit(task);

        TimeUnit.SECONDS.sleep(1);

        future.cancel(true);

        System.out.printf("Cancel status: %s\n", future.isCancelled());
        System.out.printf("Done status: %s\n", future.isDone());

        executor.shutdown();
    }
}

执行结果中，你会看到提交到执行器的任务已经被终止了。

Task is running.
Task is running.
Task is running.
Task is running.
Task is running.
Task is running.
Task is running.
Task is running.
Task is running.
Task is running.
Cancel status: true
Done status: true