Java 线程池：并发编程的必备指南

创建线程池

使用 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。
• 监控线程池的运行状态，并根据需要进行调整。
• 不再需要时关闭线程池。