Java ExecutorService在实际项目中的应用案例

以下是Java ExecutorService在实际项目中的几个典型应用案例：

1. Web应用中的异步任务处理

在Java Web应用中，可使用ExecutorService处理耗时任务（如发送邮件、生成报表），避免阻塞主线程。
案例：用户注册后异步发送欢迎邮件。

• 实现：在Servlet中创建固定大小线程池，提交邮件发送任务。

ExecutorService executor = Executors.newFixedThreadPool(5);
executor.submit(() -> sendWelcomeEmail(userEmail));
executor.shutdown();

2. 高并发请求的流量控制

通过线程池限制并发请求数，防止系统过载。
案例：电商平台的秒杀接口限流。

• 实现：使用newFixedThreadPool设置固定线程数（如100），控制同时处理秒杀请求的线程量。

ExecutorService executor = Executors.newFixedThreadPool(100);
for (int i = 0; i < 1000; i++) {
    executor.submit(() -> processSeckillRequest(request));
}
executor.shutdown();

3. 批量任务的分片并行处理

将大任务拆分为多个子任务并行执行，提升处理效率。
案例：大数据量的数据统计（如订单金额汇总）。

• 实现：将数据分片，每个分片由独立线程处理，最后合并结果。

ExecutorService executor = Executors.newFixedThreadPool(4);
List<Future<Integer>> futures = new ArrayList<>();
for (int i = 0; i < 10000; i += 1000) {
    int start = i, end = i + 1000;
    futures.add(executor.submit(() -> sumOrders(start, end)));
}
int total = futures.stream().mapToInt(future -> {
    try { return future.get(); } catch (Exception e) { return 0; }
}).sum();
executor.shutdown();

4. 定时任务调度

利用ScheduledExecutorService实现周期性任务（如日志清理、缓存刷新）。
案例：每天凌晨清理过期日志。

• 实现：使用newScheduledThreadPool设置定时任务。

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
scheduler.scheduleAtFixedRate(() -> cleanExpiredLogs(), 0, 1, TimeUnit.DAYS);

5. 并行计算场景

将计算密集型任务分解为多个子任务并行计算，缩短处理时间。
案例：计算大数组的斐波那契数列。

• 实现：将数组分段，每个段由独立线程计算，最后合并结果。

ExecutorService executor = Executors.newFixedThreadPool(8);
Future<Long> future = executor.submit(() -> computeFibonacci(10000));
System.out.println("Result: " + future.get());
executor.shutdown();

关键点总结

• 线程池类型选择：根据任务特性选择固定线程池、缓存线程池或定时线程池。
• 资源管理：务必调用shutdown()关闭线程池，避免资源泄漏。
• 异常处理：通过Future.get()捕获任务执行异常，确保程序健壮性。