如何使用Java ExecutorService实现任务取消操作

在Java中，使用ExecutorService可以方便地管理和控制线程的执行。如果你想要取消一个已经提交给ExecutorService的任务，可以使用Future对象的cancel方法。以下是一个简单的示例，展示了如何使用ExecutorService和Future来实现任务的取消操作：

1. 首先，创建一个实现了Callable接口的任务类：

import java.util.concurrent.Callable;

public class MyTask implements Callable<Boolean> {
    @Override
    public Boolean call() throws Exception {
        // 模拟一个长时间运行的任务
        for (int i = 0; i < 10; i++) {
            System.out.println("Task is running...");
            Thread.sleep(1000);
        }
        return true;
    }
}

2. 接下来，创建一个使用ExecutorService来执行任务的类：

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

public class TaskExecutor {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        MyTask myTask = new MyTask();
        Future<Boolean> future = executorService.submit(myTask);

        try {
            // 尝试在5秒后取消任务
            Thread.sleep(5000);
            boolean isCancelled = future.cancel(true);
            System.out.println("Task cancelled: " + isCancelled);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            executorService.shutdown();
        }
    }
}

在这个示例中，我们首先创建了一个ExecutorService实例，然后提交了一个MyTask任务。submit方法返回一个Future对象，我们可以使用这个对象来控制任务的执行。

在try块中，我们让主线程休眠5秒钟，然后尝试取消任务。future.cancel(true)方法会尝试中断正在执行任务的线程。如果任务已经完成或者已经被取消，cancel方法将返回false。如果任务成功取消，它将返回true。

注意，在这个示例中，我们在finally块中调用了executorService.shutdown()方法来关闭ExecutorService。这是一个很好的做法，可以确保程序在完成任务后正确地释放资源。