Executors类提供创建线程池的静态方法,包括固定大小、可缓存、单线程和定时线程池,适用于不同并发场景,但生产环境推荐手动配置ThreadPoolExecutor以更好控制参数。
在Java中,Executors 类是创建线程池最常用的方式之一。它提供了静态工厂方法,可以快速创建不同类型的线程池,简化了 ThreadPoolExecutor 的配置过程。下面介绍几种常见的使用方式和注意事项。
该方法创建一个线程数量固定的线程池,适用于任务量可预测、并发需求稳定的场景。
示例代码:
ExecutorService executor = Executors.newFixedThreadPool(4);
executor.submit(() -> {
System.out.println("任务正在执行,线程名:" + Thread.currentThread().getName());
});
// 提交多个任务...
executor.shutdown(); // 关闭线程池
说明:最多同时运行4个线程,多余任务会在队列中等待。
该线程池会根据需要创建新线程,空闲线程会被缓存60秒,适合执行大量短期异步任务。
示例代码:
ExecutorService executor = Executors.newCachedThreadPool();
for (int i = 0; i < 10; i++) {
executor.submit(() -> {
System.out.println("执行任务:" + Thread.currentThread().getName());
});
}
executor.shutdown();
注意:可能创建过多线程,导致系统资源耗尽,不适用于任务持续高负载的场景。
确保所有任务按顺序执行,相当于只有一个工作线程的线程池。
示例代码:
ExecutorService executor = Executors.newSingleThreadExecutor();
executor.submit(() -> System.out.println("第一个任务"));
executor.submit(() -> System.out.println("第二个任务"));
executor.shutdown();
输出会按提交顺序执行,适合需要保证顺序处理的场景。
用于执行定时任务或周期性任务,类似于 Timer 的增强版。
示例代码(延迟3秒后执行):
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
scheduler.schedule(() -> {
System.out.println("延迟任务执行");
}, 3, TimeUnit.SECONDS);
示例代码(周期性执行,每2秒一次):
scheduler.scheduleAtFixedRate(() -> {
System.out.println("周期性任务执行:" + System.currentTimeMillis());
}, 0, 2, TimeUnit.SECONDS);
记得调用 shutdown() 停止调度,否则程序不会退出。
基本上就这些。使用 Executors 能快速搭建线程池,但在生产环
境中建议根据实际需求通过 ThreadPoolExecutor 手动构建,以更精确控制队列大小、拒绝策略等参数,避免潜在风险。