Java 浅析线程池ThreadPoolExecutor

问：池化技术是什么？
答：事先准备好一些资源，有人要用，就来我这里拿，用完之后还给我。

---

线程池需要掌握：

1. 三个方法
2. 七个参数
3. 四个拒绝策略

---

使用线程池的好处：

1. 降低资源的消耗
2. 提高响应的速度
3. 方便管理（线程复用，可以控制最大并发数、管理线程）

---

三个方法：

// 创建单个线程
ExecutorService threadPool = Executors.newSingleThreadExecutor();
// 创建固定个数线程
ExecutorService threadPool = Executors.newFixedThreadPool(5);
// 创建最大缓存数线程（2^23 -1）
ExecutorService threadPool = Executors.newCachedThreadPool()
1
2
3
4
5
6

在《阿里巴巴开发手册》中有提到，不允许使用Executors去创建线程池，而是用更底层的ThreadPoolExecutor创建线程池。

—

---

七个参数：

上文提到使用ThreadPoolExecutor创建线程池，我们来看一下ThreadPoolExecutor构造函数的参数：

Executors.newSingleThreadExecutor 和 Executors.newFixedThreadPool 实际上就是设置了 corePoolSize 和 maximumPoolSize ，从而控制线程池的线程数量。

---

四个拒绝策略：

// 超过最大承载, 拒绝并抛出异常
ThreadPoolExecutor.AbortPolicy()
// 哪里来的去哪里
ThreadPoolExecutor.CallerRunsPolicy()
// 队列满了, 丢掉任务, 不会抛出异常
ThreadPoolExecutor.DiscardPolicy()
// 队列满了, 尝试去和最早的竞争, 竞争失败丢掉任务, 不会抛出异常
ThreadPoolExecutor.DiscardOldestPolicy()
1
2
3
4
5
6
7
8

在 Executors.newSingleThreadExecutor 的源码中可以找到默认的拒绝策略是AbortPolicy( )。

---

举例说明：

线程池的运作和银行营业大厅是一样的：
大厅有固定的窗口是一直开启的，这是线程池中的核心线程池；
而有一些窗口只有在办理业务的人比较多的时候才会开启，这是闲置窗口。核心窗口 + 闲置窗口 = 最大并发量；
大厅里的业务等候区是阻塞队列；
当核心窗口、闲置窗口、业务等候区都满了，依旧有人进来办理业务，这时需要一些拒绝策略，要么让他在外面等着，要么让他换个地方。

ExecutorService threadPool = new ThreadPoolExecutor(
                2,
                5,
                3,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(3),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy()); // AbortPolicy() 默认拒绝策略,银行满了,还有人进来,不处理这个人,抛出异常

try {
    // execute调用线程
    for (int i = 1; i <= 10; i++) {
        threadPool.execute(() -> {
            System.out.println(Thread.currentThread().getName() + " ok");
        });
    }
} catch (Exception e) {
    e.printStackTrace();
} finally {
    // 线程池用完, 程序结束, 关闭线程池!
    threadPool.shutdown();
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

---

线程池的最大值大小如何设置？

1. CPU密集型：Runtime.getRuntime().availableProcessors() 获取设备逻辑处理器

2. IO密集型：判断程序中十分耗IO的线程, 只要大于这个数就好(2倍)