Java Executor执行器如何实现批量处理任务

在Java中，使用ExecutorService可以方便地实现批量处理任务。ExecutorService是一个接口，它提供了一种将任务提交给线程池执行的方式。以下是使用ExecutorService实现批量处理任务的步骤：

1. 创建一个实现了Runnable或Callable接口的任务类。这个类需要实现run()方法（对于Runnable）或call()方法（对于Callable），在这些方法中编写具体的任务逻辑。

public class MyTask implements Runnable {
    private int taskId;

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

    @Override
    public void run() {
        System.out.println("Task " + taskId + " is running.");
    }
}

2. 创建一个ExecutorService实例。可以使用Executors工具类创建一个固定大小的线程池，或者创建一个缓存线程池。

ExecutorService executorService = Executors.newFixedThreadPool(5);

3. 使用ExecutorService的submit()方法提交任务。可以将任务添加到一个List中，然后遍历这个列表，将每个任务提交给线程池。

List<MyTask> tasks = new ArrayList<>();
for (int i = 0; i < 10; i++) {
    MyTask task = new MyTask(i);
    tasks.add(task);
    executorService.submit(task);
}

4. 关闭ExecutorService。在所有任务都提交完成后，调用shutdown()方法关闭线程池。这将阻止新的任务被提交，并等待已提交的任务完成。

executorService.shutdown();

5. （可选）等待所有任务完成。如果需要确保所有任务都已完成，可以使用awaitTermination()方法等待线程池终止。

try {
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    executorService.shutdownNow();
}

这是一个完整的示例：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class BatchProcessingExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(5);

        List<MyTask> tasks = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            MyTask task = new MyTask(i);
            tasks.add(task);
            executorService.submit(task);
        }

        executorService.shutdown();

        try {
            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }
    }
}

class MyTask implements Runnable {
    private int taskId;

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

    @Override
    public void run() {
        System.out.println("Task " + taskId + " is running.");
    }
}

这个示例中，我们创建了一个固定大小为5的线程池，并提交了10个任务。线程池会自动分配线程来执行这些任务。