Java Executor执行器如何实现任务取消

在Java中，使用ExecutorService接口和Future对象可以实现任务的取消。以下是一个简单的示例，展示了如何使用ExecutorService和Future来执行任务并取消它：

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

public class ExecutorCancellationExample {

    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(2);

        // 提交一个任务并获取Future对象
        Future<?> future = executorService.submit(() -> {
            try {
                System.out.println("任务开始执行");
                // 模拟长时间运行的任务
                TimeUnit.SECONDS.sleep(10);
                System.out.println("任务执行完成");
            } catch (InterruptedException e) {
                System.out.println("任务被取消");
            }
        });

        // 在5秒后取消任务
        try {
            TimeUnit.SECONDS.sleep(5);
            boolean isCancelled = future.cancel(true); // 设置为true表示如果任务正在运行，应该中断它
            System.out.println("任务取消状态: " + isCancelled);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 关闭线程池
        executorService.shutdown();
    }
}

在这个示例中，我们创建了一个固定大小的线程池，并提交了一个长时间运行的任务。然后，在5秒后，我们尝试取消这个任务。如果任务已经开始执行，future.cancel(true)会尝试中断它。需要注意的是，任务必须能够响应中断请求，即在任务中检查Thread.currentThread().isInterrupted()并在适当的时候退出。

如果任务已经完成或者已经被取消，future.cancel()将返回false。如果任务成功取消，它将返回true。

请记住，取消一个任务并不意味着它会立即停止。任务需要定期检查中断状态，并在检测到中断时退出。如果任务不响应中断，它可能会继续运行，即使你调用了cancel()方法。