Java并发工具库中的线程池设计案例

原创妖狐艹你老母 2024-11-06 03:15 14阅读 0赞

Java并发工具库中，`java.util.concurrent`包提供了强大的线程池实现，主要通过`Executor`框架来实现。以下是一些常见的线程池设计案例：

1. **固定大小的线程池（FixedThreadPool）**：
固定大小的线程池适用于负载较重的服务器，它可以控制线程的最大并发数，超出的线程会在队列中等待。

```javaExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);
 ```2. **单线程的线程池（SingleThreadExecutor）**：
单线程的线程池适用于需要保证任务顺序执行的场景。

```javaExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
 ```3. **可缓存的线程池（CachedThreadPool）**：
可缓存的线程池会根据需要创建新线程的线程池，如果线程空闲超过60秒，则会被回收。

```javaExecutorService cachedThreadPool = Executors.newCachedThreadPool();
 ```4. **定时及周期性任务的线程池（ScheduledThreadPool）**：
适用于需要定时或周期性执行任务的场景。

```java ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
 ```5. **自定义线程池**：
如果内置的线程池不能满足需求，可以自定义线程池。自定义线程池可以设置线程工厂、拒绝策略等。

```javaint corePoolSize =10;
int maximumPoolSize =50;
 long keepAliveTime =120;
 TimeUnit unit = TimeUnit.SECONDS;
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(100);
ThreadFactory threadFactory = Executors.defaultThreadFactory();
RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy();
ExecutorService customThreadPool = new ThreadPoolExecutor(
corePoolSize,
 maximumPoolSize,
 keepAliveTime,
unit,
 workQueue,
 threadFactory,
 handler);
 ```6. **使用`Executors`工厂方法的局限性**：
`Executors`提供的工厂方法虽然方便，但它们返回的线程池在某些情况下可能不是最优的。例如，`Executors.newCachedThreadPool()`和`Executors.newFixedThreadPool()`在JDK9中已经被标记为过时，因为它们可能在某些情况下导致资源耗尽。

7. **合理关闭线程池**：
当不再需要线程池时，应该正确关闭它，以释放资源。

```java fixedThreadPool.shutdown();
 try {
if (!fixedThreadPool.awaitTermination(60, TimeUnit.SECONDS)) {
 fixedThreadPool.shutdownNow();
 }
} catch (InterruptedException ex) {
 fixedThreadPool.shutdownNow();
Thread.currentThread().interrupt();
 }
 ```在设计线程池时，需要考虑任务的性质（CPU密集型、IO密集型）、预期的并发量、资源限制等因素，以选择或设计合适的线程池。