如何使用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。這是一個很好的做法，可以確保程序在完成任務后正確地釋放資源。