如何使用Java ExecutorService进行批量处理

在Java中，ExecutorService是一个用于管理线程池和执行异步任务的接口。通过使用ExecutorService，你可以轻松地实现批量处理任务

1. 导入必要的包：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

2. 创建一个实现Callable接口的任务类：

class BatchTask implements Callable<Integer> {
    private int taskId;

    public BatchTask(int taskId) {
        this.taskId = taskId;
    }

    @Override
    public Integer call() throws Exception {
        System.out.println("执行任务: " + taskId);
        Thread.sleep(1000); // 模拟耗时操作
        return taskId * 2;
    }
}

3. 创建一个批量处理任务的方法：

public static List<Integer> executeBatchTasks(List<Callable<Integer>> tasks) throws InterruptedException, ExecutionException {
    ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池
    List<Integer> results = new ArrayList<>();

    try {
        // 提交所有任务并获取Future列表
        List<Future<Integer>> futures = executorService.invokeAll(tasks);

        // 遍历Future列表，获取任务执行结果
        for (Future<Integer> future : futures) {
            results.add(future.get());
        }
    } finally {
        executorService.shutdown(); // 关闭线程池
    }

    return results;
}

4. 在主方法中调用批量处理任务的方法：

public static void main(String[] args) {
    List<Callable<Integer>> tasks = new ArrayList<>();
    for (int i = 0; i < 10; i++) {
        tasks.add(new BatchTask(i));
    }

    try {
        List<Integer> results = executeBatchTasks(tasks);
        System.out.println("任务执行结果: " + results);
    } catch (InterruptedException | ExecutionException e) {
        e.printStackTrace();
    }
}

这个示例中，我们创建了一个BatchTask类，它实现了Callable接口。然后，我们创建了一个executeBatchTasks方法，该方法接受一个Callable任务列表，并使用ExecutorService来执行这些任务。最后，在主方法中，我们创建了一个任务列表并调用了executeBatchTasks方法来执行这些任务。