- 资源利用率提高:线程池避免了频繁创建和销毁线程的开销,从而节省了资源。
- 并发控制:线程池允许您控制并发线程的数量,防止系统过载。
- 任务调度:您可以根据优先级或其他策略安排任务,从而优化任务执行。
创建线程池
使用 java.util.concurrent.Executors
类创建线程池:
// 创建固定大小的线程池
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);
// 创建可缓存的线程池
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
// 创建单线程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
任务提交
要向线程池提交任务,请使用以下方法:
execute(Runnable task)
:提交一个不返回任何结果的任务。submit(Callable task)
:提交一个返回结果的任务。
线程池配置
在创建线程池时,可以配置以下属性:
- 大小:固定大小线程池中的线程数或可缓存线程池中的最大线程数。
- 核心大小:可缓存线程池中的最小线程数。
- 队列: 用于存储等待执行的任务的队列。
- 拒绝策略:当线程池饱和时,决定如何处理新任务。
拒绝策略
当线程池饱和时,可以使用以下拒绝策略:
AbortPolicy
:抛出RejectedExecutionException
。CallerRunsPolicy
:在调用线程中执行任务。DiscardOldestPolicy
:丢弃队列中最旧的任务。DiscardPolicy
:丢弃新任务。
监控线程池
使用 getPoolSize()
、getQueueSize()
和 getActiveCount()
等方法监控线程池的运行状况。您还可以使用 ExecutorServiceMXBean
获取有关线程池的更详细信息。
关闭线程池
在不再需要线程池时,请使用 shutdown()
或 shutdownNow()
方法关闭它。这将停止接受新任务并等待所有当前任务完成。
最佳实践
- 选择适合应用程序需求的线程池大小和队列大小。
- 优先使用
Callable
,因为它允许任务返回结果。 - 处理可能抛出的
RejectedExecutionException
。 - 监控线程池的运行状况,并根据需要进行调整。
- 在不再需要时关闭线程池。