hooyantsing's Blog

23_7大参数及自定义线程池

字数统计: 516阅读时长: 2 min
2020/08/27

23 7大参数及自定义线程池

狂神说Java JUC并发编程最新版通俗易懂

解释线程池内部

201812241107535.png

7大参数

可以通过查看 3大方法的源码实现,发现都是使用的 ThreadPoolExecutor 对象,因此可以通过 ThreadPoolExecutor 自定义线程池。

阿里巴巴规范:禁止使用 Executors 工具类(3大方法)创建线程池,应使用 ThreadPoolExecutor 自定义线程池,详见开发手册

自定义线程池

七大参数

  1. 核心线程数
  2. 最大线程数
  3. 超时时间
  4. 时间单位
  5. 队列类型
  6. 线程工厂
  7. 拒绝策略
    ExecutorService threadPool = new ThreadPoolExecutor(

2, // 基础线程数,最小线程数

5, // 扩容线程数,最大线程数。当队列满时,激活。

3, // 时间。如果没有请求,超过时间后销毁扩容线程。

TimeUnit.SECONDS, // 时间单位

new LinkedBlockingDeque<>(3), // 队列类型

Executors.defaultThreadFactory(), // 默认,线程工厂

new ThreadPoolExecutor.AbortPolicy() // 4种拒绝策略

);

案例
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
package pool;

import java.util.concurrent.*;

public class Demo02 {
public static void main(String[] args) {
ExecutorService threadPool = new ThreadPoolExecutor(
2, // 基础线程数,最小线程数
5, // 扩容线程数,最大线程数。当队列满时,激活。
3, // 时间。如果没有请求,超过时间后销毁扩容线程。
TimeUnit.SECONDS, // 时间单位
new LinkedBlockingDeque<>(3), // 队列类型
Executors.defaultThreadFactory(), // 默认,线程工厂
new ThreadPoolExecutor.AbortPolicy() // 4种拒绝策略
);

try {
for (int i = 0; i < 100; i++) {
threadPool.execute(
() -> {
System.out.println(Thread.currentThread().getName());
}
);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 线程池用完,关闭
threadPool.shutdown();
}
}
}

4种拒绝策略

查看源码,4种拒绝策略均实现了 RejectedExecutionHandler 接口。

  • AbortPolicy 直接抛出拒绝异常
  • CallerRunsPolicy 只会用调用者所在线程来运行任务,也就是说任务不会进入线程池。
  • DiscardOledestPolicy 丢弃队列中最老的,然后再次尝试提交新任务。
  • DiscardPolicy 默默丢弃无法加载的任务。
    详见 辅佐资料_Java java线程池的拒绝策略 - 简书
CATALOG
  1. 1. 23 7大参数及自定义线程池
    1. 1.0.1. 解释线程池内部
    2. 1.0.2. 7大参数
      1. 1.0.2.1. 自定义线程池
      2. 1.0.2.2. 案例
    3. 1.0.3. 4种拒绝策略