Java ExecutorService如何实现批量任务处理

在Java中，ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。要实现批量任务处理，你可以使用ExecutorService的invokeAll()方法。这个方法接收一个Collection类型的参数，其中包含多个Callable或Runnable任务。invokeAll()方法会提交所有任务，并在所有任务完成后返回一个List<Future>，其中包含了每个任务的执行结果。

下面是一个简单的示例，展示了如何使用ExecutorService实现批量任务处理：

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

public class BatchTaskProcessing {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        // 创建一个任务列表
        List<Callable<String>> tasks = new ArrayList<>();
        tasks.add(() -> {
            Thread.sleep(1000);
            return "Task 1 completed";
        });
        tasks.add(() -> {
            Thread.sleep(2000);
            return "Task 2 completed";
        });
        tasks.add(() -> {
            Thread.sleep(3000);
            return "Task 3 completed";
        });

        try {
            // 提交所有任务并等待它们完成
            List<Future<String>> results = executorService.invokeAll(tasks);

            // 输出任务执行结果
            for (Future<String> result : results) {
                System.out.println(result.get());
            }
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            // 关闭线程池
            executorService.shutdown();
        }
    }
}

在这个示例中，我们创建了一个固定大小为5的线程池，并添加了3个任务。invokeAll()方法会等待所有任务完成后返回结果。然后我们遍历Future列表，输出每个任务的执行结果。最后，我们关闭线程池。