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执行异步任务时实现进度跟踪。你可以根据自己的需求选择合适的方法。