Java Executor执行器如何实现任务进度监控

在Java中，使用ExecutorService执行异步任务时，可以通过以下几种方式实现任务进度监控：

1. 使用Future接口：

当提交一个任务给ExecutorService时，可以使用submit()方法返回一个Future对象。通过调用Future对象的get()方法，可以阻塞等待任务完成并获取结果。但是，这种方法无法直接监控任务进度。为了实现进度监控，可以在任务内部定期调用Future对象的reportProgress()方法（需要自定义一个带有进度报告功能的Future接口）。

public interface ProgressFuture<V> extends Future<V> {
    void reportProgress(int progress);
}

public class ProgressFutureImpl<V> implements ProgressFuture<V> {
    private final Future<V> future;

    public ProgressFutureImpl(Future<V> future) {
        this.future = future;
    }

    @Override
    public boolean cancel(boolean mayInterruptIfRunning) {
        return future.cancel(mayInterruptIfRunning);
    }

    @Override
    public boolean isCancelled() {
        return future.isCancelled();
    }

    @Override
    public boolean isDone() {
        return future.isDone();
    }

    @Override
    public V get() throws InterruptedException, ExecutionException {
        return future.get();
    }

    @Override
    public V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
        return future.get(timeout, unit);
    }

    @Override
    public void reportProgress(int progress) {
        // 实现进度报告功能，例如更新UI或者记录日志等
    }
}

然后在任务内部定期调用reportProgress()方法来报告进度。

2. 使用CompletionService接口：

CompletionService接口可以将任务的执行和结果的获取分离。通过这种方式，可以在任务完成时立即获取结果，而不需要阻塞等待所有任务完成。这样可以更方便地监控任务的进度。

ExecutorService executorService = Executors.newFixedThreadPool(10);
CompletionService<Integer> completionService = new ExecutorCompletionService<>(executorService);

for (int i = 0; i < 10; i++) {
    final int taskId = i;
    completionService.submit(() -> {
        // 执行任务并报告进度
        for (int j = 0; j <= 100; j += 10) {
            // 模拟任务进度
            Thread.sleep(100);
            System.out.println("Task " + taskId + " progress: " + j + "%");
        }
        return taskId;
    });
}

for (int i = 0; i < 10; i++) {
    try {
        Future<Integer> completedTask = completionService.take();
        int taskId = completedTask.get();
        System.out.println("Task " + taskId + " completed.");
    } catch (InterruptedException | ExecutionException e) {
        e.printStackTrace();
    }
}

executorService.shutdown();

3. 使用第三方库：

有一些第三方库提供了更高级的任务进度监控功能，例如CompletableFuture。CompletableFuture是Java 8引入的一个类，它提供了丰富的API来处理异步任务，包括任务进度监控。

CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(() -> {
    // 执行任务并报告进度
    for (int j = 0; j <= 100; j += 10) {
        // 模拟任务进度
        try {
            Thread.sleep(100);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task progress: " + j + "%");
    }
    return 42;
}, executorService);

completableFuture.thenAccept(result -> {
    System.out.println("Task completed with result: " + result);
});

executorService.shutdown();

这些方法可以帮助你在Java中实现任务进度监控。你可以根据自己的需求选择合适的方法。