在Java中如何使用ExecutorService批量执行任务_ExecutorService并发管理技巧

• 使用 List 存储 Future，便于统一管理异步结果
• Runnable 用于无返回值的任务，Callable 可返回结果并支持泛型
• 调用 Future.get() 可阻塞等待任务完成，注意设置超时避免无限等待

ExecutorService executor = Executors.newFixedThreadPool(4);
List> results = new ArrayList<>();
for (int i = 0; i < 10; i++) {
final int taskId = i;
Callable task = () -> "Task " + taskId + " completed by " + Thread.currentThread().getName();
results.add(executor.submit(task));
}
// 获取结果
for (Future result : results) {
try {
System.out.println(result.get(5, TimeUnit.SECONDS)); // 设置超时
} catch (TimeoutException e) {
System.err.println("任务执行超时");
}
}

• 核心线程数：保持常驻的线程数量，根据CPU核心数和任务类型设定
• 最大线程数：控制并发上限，防止资源耗尽
• 工作队列：选择合适的阻塞队列（如 LinkedBlockingQueue、ArrayBlockingQueue）
• 拒绝策略：定义任务过多时的处理方式，如 AbortPolicy、CallerRunsPolicy

int corePoolSize = Runtime.getRuntime().availableProcessors();
int maxPoolSize = corePoolSize * 2;
long keepAliveTime = 60L;
ThreadPoolExecutor executor = new ThreadPoolExecutor(
corePoolSize,
maxPoolSize,
keepAliveTime,
TimeUnit.SECONDS,
new ArrayBlockingQueue<>(100),
new ThreadPoolExecutor.CallerRunsPolicy()
);

• 调用 shutdown() 表示不再接收新任务
• 配合 awaitTermination() 等待所有任务结束
• 设置合理的等待时间，避免程序卡住

executor.shutdown();
try {
    if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
        executor.shutdownNow(); // 强制中断
    }
} catch (InterruptedException e) {
    executor.shutdownNow();
    Thread.currentThread().interrupt();
}

• 在 Callable 中 try-catch 异常并封装到返回值中
• 为线程池设置 UncaughtExceptionHandler，记录日志
• 定期检查 Future 状态，及时发现失败任务
• 结合监控工具（如 Micrometer）统计活跃线程数、队列长度等指标

ThreadFactory namedFactory = r -> {
    Thread t = new Thread(r);
    t.setUncaughtExceptionHandler((t, e) -> 
        System.err.println("Thread " + t.getName() + " failed: " + e.getMessage())
    );
    return t;
};