Java线程池种类及具体应用场景

Java线程池种类及具体应用场景

在实际开辟中，选择符合的线程池范例至关紧张，差别场景有差别的线程池需求。本文将连合线程池种类和具体应用示例，具体阐明每种线程池的利用场景和实用环境。

---

一、固定巨细线程池（FixedThreadPool）

特点

• 线程数量固定：线程池中的线程数固定，凌驾的任务会被放入队列期待实行。
  
• 任务队列无界：会生存全部期待实行的任务。
  

实用场景

实用于任务量确定且须要长期运行的场景，比方：

• 处置惩罚固定命目标并发任务。
  
• 须要对线程数量严格控制，制止资源耗尽。
  

应用示例：文件批量处置惩罚

1. import java.util.concurrent.ExecutorService;
2. import java.util.concurrent.Executors;
4. public class FixedThreadPoolExample {
5.     public static void main(String[] args) {
6.         ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
8.         // 模拟批量处理文件
9.         for (int i = 1; i <= 10; i++) {
10.             int fileNumber = i;
11.             fixedThreadPool.execute(() -> {
12.                 System.out.println(Thread.currentThread().getName() + " 正在处理文件 " + fileNumber);
13.                 try {
14.                     Thread.sleep(1000); // 模拟文件处理耗时
15.                 } catch (InterruptedException e) {
16.                     e.printStackTrace();
17.                 }
18.             });
19.         }
21.         fixedThreadPool.shutdown();
22.     }
23. }

复制代码

输出示例：

1. pool-1-thread-1 正在处理文件 1
2. pool-1-thread-2 正在处理文件 2
3. pool-1-thread-3 正在处理文件 3

复制代码

---

二、单线程池（SingleThreadExecutor）

特点

• 单线程：始终只有一个线程实行任务，任务按提交次序依次实行。
  
• 任务队列无界：任务不会丢失。
  

实用场景

实用于须要按次序实行任务的场景，比方：

• 日志写入。
  
• 数据库备份任务。
  

应用示例：按次序写入日志

1. import java.util.concurrent.ExecutorService;
2. import java.util.concurrent.Executors;
4. public class SingleThreadExecutorExample {
5.     public static void main(String[] args) {
6.         ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
8.         // 模拟日志写入
9.         for (int i = 1; i <= 5; i++) {
10.             int logNumber = i;
11.             singleThreadExecutor.execute(() -> {
12.                 System.out.println("写入日志：" + logNumber);
13.             });
14.         }
16.         singleThreadExecutor.shutdown();
17.     }
18. }

复制代码

输出示例：

1. 写入日志：1
2. 写入日志：2
3. 写入日志：3

复制代码

---

三、可缓存线程池（CachedThreadPool）

特点

• 线程数动态增长：没有核心线程，全部任务都创建新线程处置惩罚；线程空闲超时后会被烧毁。
  
• 任务队列无界：适当短期大量任务。
  

实用场景

实用于实行大量短生命周期的任务，比方：

• 服务器处置惩罚大量暂时任务。
  
• 并发测试。
  

应用示例：并发哀求处置惩罚

1. import java.util.concurrent.ExecutorService;
2. import java.util.concurrent.Executors;
4. public class CachedThreadPoolExample {
5.     public static void main(String[] args) {
6.         ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
8.         // 模拟并发请求
9.         for (int i = 1; i <= 10; i++) {
10.             int requestNumber = i;
11.             cachedThreadPool.execute(() -> {
12.                 System.out.println(Thread.currentThread().getName() + " 正在处理请求 " + requestNumber);
13.             });
14.         }
16.         cachedThreadPool.shutdown();
17.     }
18. }

复制代码

输出示例：

1. pool-1-thread-1 正在处理请求 1
2. pool-1-thread-2 正在处理请求 2
3. pool-1-thread-3 正在处理请求 3

复制代码

---

四、定时任务线程池（ScheduledThreadPool）

特点

• 支持定时和周期性任务：可以耽误实行任务，也可以周期性实行任务。
  
• 线程数固定：线程池巨细由开辟者设置。
  

实用场景

实用于须要定时或周期性实行任务的场景，比方：

• 定时任务提示。
  
• 周期性数据同步。
  

应用示例：定时任务调治

1. import java.util.concurrent.Executors;
2. import java.util.concurrent.ScheduledExecutorService;
3. import java.util.concurrent.TimeUnit;
5. public class ScheduledThreadPoolExample {
6.     public static void main(String[] args) {
7.         ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(2);
9.         // 延迟3秒执行任务
10.         scheduledThreadPool.schedule(() -> {
11.             System.out.println("任务延迟3秒后执行");
12.         }, 3, TimeUnit.SECONDS);
14.         // 每2秒执行一次任务
15.         scheduledThreadPool.scheduleAtFixedRate(() -> {
16.             System.out.println("周期任务，每2秒执行一次");
17.         }, 1, 2, TimeUnit.SECONDS);
19.         // 每3秒执行一次任务
20.         scheduledThreadPool.scheduleWithFixedDelay(() -> {
21.             System.out.println("固定延迟任务，每3秒延迟执行");
22.         }, 1, 3, TimeUnit.SECONDS);
23.     }
24. }

复制代码

---

五、自界说线程池

特点

• 根据业务需求机动设置参数。
  
• 通过自界说拒绝计谋、任务队列、线程工厂等满意特定需求。
  

实用场景

实用于对线程池有特别要求的场景，比方：

• 限定任务队列巨细。
  
• 自界说日志记录线程工厂。
  

应用示例：控制线程数量并记录日志

1. import java.util.concurrent.*;
3. public class CustomThreadPoolExample {
4.     public static void main(String[] args) {
5.         ThreadPoolExecutor customThreadPool = new ThreadPoolExecutor(
6.             2, // 核心线程数
7.             4, // 最大线程数
8.             60, // 空闲线程存活时间
9.             TimeUnit.SECONDS, // 时间单位
10.             new ArrayBlockingQueue<>(2), // 有界队列
11.             r -> { // 自定义线程工厂
12.                 Thread thread = new Thread(r);
13.                 thread.setName("自定义线程-" + thread.getId());
14.                 return thread;
15.             },
16.             new ThreadPoolExecutor.CallerRunsPolicy() // 拒绝策略
17.         );
19.         for (int i = 1; i <= 10; i++) {
20.             int taskNumber = i;
21.             customThreadPool.execute(() -> {
22.                 System.out.println(Thread.currentThread().getName() + " 正在执行任务 " + taskNumber);
23.                 try {
24.                     Thread.sleep(1000); // 模拟任务耗时
25.                 } catch (InterruptedException e) {
26.                     e.printStackTrace();
27.                 }
28.             });
29.         }
31.         customThreadPool.shutdown();
32.     }
33. }

复制代码

---

总结

线程池范例特点应用场景示例应用FixedThreadPool固定巨细线程池，无界任务队列并发量稳固的长期任务，任务耗时较长文件处置惩罚SingleThreadExecutor单线程，按次序实行任务须要任务次序实行的场景日志记录CachedThreadPool动态线程数，可快速处置惩罚大量短任务短生命周期的并发任务并发哀求处置惩罚ScheduledThreadPool支持定时和周期性任务定时任务、周期性任务调治任务提示，数据同步自界说线程池参数机动，满意特别需求高级任务管理限定队列巨细，拒绝计谋根据实际场景选择符合的线程池，既能优化体系性能，又能公道分配资源。