Java ExecutorService如何實現任務進度跟蹤

在Java中，使用ExecutorService執行異步任務時，可以通過以下幾種方法實現任務進度跟蹤：

1. 使用Future接口：

當提交一個任務給ExecutorService時，可以使用submit()方法而不是execute()方法。submit()方法會返回一個Future對象，通過這個對象可以查詢任務的執行狀態和結果。

ExecutorService executorService = Executors.newFixedThreadPool(5);
Future<Integer> future = executorService.submit(new Callable<Integer>() {
    @Override
    public Integer call() throws Exception {
        int sum = 0;
        for (int i = 0; i <= 100; i++) {
            sum += i;
            // 更新進度
            updateProgress(i);
        }
        return sum;
    }
});

// 檢查任務是否完成
if (future.isDone()) {
    // 獲取任務結果
    int result = future.get();
    System.out.println("任務結果: " + result);
}

2. 使用自定義的進度監聽器：

可以創建一個進度監聽器接口，并在任務中定期調用該接口的方法來更新進度。

public interface ProgressListener {
    void onProgressUpdate(int progress);
}

public class MyTask implements Callable<Integer> {
    private final ProgressListener listener;

    public MyTask(ProgressListener listener) {
        this.listener = listener;
    }

    @Override
    public Integer call() throws Exception {
        int sum = 0;
        for (int i = 0; i <= 100; i++) {
            sum += i;
            // 更新進度
            listener.onProgressUpdate(i);
        }
        return sum;
    }
}

// 使用任務
ExecutorService executorService = Executors.newFixedThreadPool(5);
ProgressListener listener = new ProgressListener() {
    @Override
    public void onProgressUpdate(int progress) {
        System.out.println("任務進度: " + progress + "%");
    }
};
Future<Integer> future = executorService.submit(new MyTask(listener));

3. 使用CompletableFuture：

CompletableFuture是Java 8引入的一個類，它提供了更強大的異步編程功能，包括任務進度跟蹤。

ExecutorService executorService = Executors.newFixedThreadPool(5);
CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(() -> {
    int sum = 0;
    for (int i = 0; i <= 100; i++) {
        sum += i;
        // 更新進度
        updateProgress(i);
    }
    return sum;
}, executorService);

// 檢查任務是否完成
completableFuture.thenAccept(result -> System.out.println("任務結果: " + result));

// 監聽任務進度
completableFuture.thenAccept(progress -> System.out.println("任務進度: " + progress + "%"));

這些方法可以幫助你在使用ExecutorService執行異步任務時實現進度跟蹤。你可以根據自己的需求選擇合適的方法。