2
2
3
3
Java5中的线程并发库都在java.util.concurrent包及子包中
4
4
5
- # ** 1. Executor类的继承结构**
5
+ # 1. Executor类的继承结构
6
6
7
- ![ ThreadPoolExecutor] ( http:// img.blog.csdn.net/20161024205013699 )
7
+ ![ ThreadPoolExecutor] ( img/thread_pool_01.png )
8
8
9
9
![ ] ( img/threadpoolexecutor.png )
10
10
@@ -24,9 +24,11 @@ ExecutorService是Executor的子接口,该接口中包含了线程池常用的
24
24
| submit() | 提交任务 |
25
25
| invokeAll() | 执行一组任务 |
26
26
27
- # ** 2. ThreadPoolExecutor**
27
+ # 2. ThreadPoolExecutor
28
+
28
29
ExecutorService的默认实现,同时也是Executors的底层实现
29
- ## ** 2.1 构造方法**
30
+
31
+ ## 2.1 构造方法
30
32
31
33
``` java
32
34
public ThreadPoolExecutor(
@@ -39,19 +41,19 @@ public ThreadPoolExecutor(
39
41
RejectedExecutionHandler handler // 异常捕获器
40
42
)
41
43
```
42
- ### ** 2.1.1 int corePoolSize**
44
+ ### 2.1.1 int corePoolSize
43
45
44
46
核心池的大小,这个参数跟后面讲述的线程池的实现原理有非常大的关系。在创建了线程池后,默认情况下,线程池中并没有任何线程,而是等待有任务到来才创建线程去执行任务,除非调用了prestartAllCoreThreads()或者prestartCoreThread()方法,从这2个方法的名字就可以看出,是预创建线程的意思,即在没有任务到来之前就创建corePoolSize个线程或者一个线程。默认情况下,在创建了线程池后,线程池中的线程数为0,当有任务来之后,就会创建一个线程去执行任务,当线程池中的线程数目达到corePoolSize后,就会把到达的任务放到缓存队列当中
45
47
46
- ### ** 2.1.2 int maximumPoolSize**
48
+ ### 2.1.2 int maximumPoolSize
47
49
48
50
线程池最大线程数,这个参数也是一个非常重要的参数,它表示在线程池中最多能创建多少个线程
49
51
50
- ### ** 2.1.3 long keepAliveTime**
52
+ ### 2.1.3 long keepAliveTime
51
53
52
54
表示线程没有任务执行时最多保持多久时间会终止。默认情况下,只有当线程池中的线程数大于corePoolSize时,keepAliveTime才会起作用,直到线程池中的线程数不大于corePoolSize,即当线程池中的线程数大于corePoolSize时,如果一个线程空闲的时间达到keepAliveTime,则会终止,直到线程池中的线程数不超过corePoolSize。但是如果调用了allowCoreThreadTimeOut(boolean)方法,在线程池中的线程数不大于corePoolSize时,keepAliveTime参数也会起作用,直到线程池中的线程数为0
53
55
54
- ### ** 2.1.4 TimeUnit unit**
56
+ ### 2.1.4 TimeUnit unit
55
57
56
58
参数keepAliveTime的时间单位,有7种取值
57
59
@@ -63,7 +65,7 @@ public ThreadPoolExecutor(
63
65
- TimeUnit.MICROSECONDS //微妙
64
66
- TimeUnit.NANOSECONDS //纳秒
65
67
66
- ### ** 2.1.5 RejectedExecutionHandler**
68
+ ### 2.1.5 RejectedExecutionHandler
67
69
68
70
当线程池和workQueue都满了的情况下,对新加任务采取的处理策略也有几个默认的实现,分别如下
69
71
@@ -79,28 +81,29 @@ public ThreadPoolExecutor(
79
81
- ThreadPoolExecutor.CallerRunsPolicy
80
82
拒绝新任务进入,如果该线程池还没有被关闭,那么由调用线程处理该任务
81
83
82
- # ** 3. 任务提交给线程池之后的处理策略**
84
+ # 3. 任务提交给线程池之后的处理策略
85
+
83
86
3.1 如果当前线程池中的线程数目小于corePoolSize,则每来一个任务,就会创建线程执行这个任务
84
87
85
- ![ ThreadPoolExecutor] ( http:// img.blog.csdn.net/20161025001312662 )
88
+ ![ ThreadPoolExecutor] ( img/thread_pool_02.png )
86
89
87
90
3.2 如果当前线程池中的线程数目>=corePoolSize,则每来一个任务,会尝试将其添加到任务缓存队列当中
88
91
89
92
3.2.1 若添加成功,则该任务会等待空闲线程将其取出去执行
90
93
91
- ![ ThreadPoolExecutor] ( http:// img.blog.csdn.net/20161025001328454 )
94
+ ![ ThreadPoolExecutor] ( img/thread_pool_03.png )
92
95
93
96
3.2.2 若添加失败(一般来说是任务缓存队列已满),则会尝试创建新的线程去执行这个任务
94
97
95
- ![ ThreadPoolExecutor] ( http:// img.blog.csdn.net/20161025001336913 )
98
+ ![ ThreadPoolExecutor] ( img/thread_pool_04.png )
96
99
97
100
3.3 如果当前线程池中的线程数目达到maximumPoolSize,则会采取任务拒绝策略进行处理
98
101
99
- ![ ThreadPoolExecutor] ( http:// img.blog.csdn.net/20161025001349032 )
102
+ ![ ThreadPoolExecutor] ( img/thread_pool_05.png )
100
103
101
104
如果线程池中的线程数量大于 corePoolSize时,如果某线程空闲时间超过keepAliveTime,线程将被终止,直至线程池中的线程数目不大于corePoolSize;如果允许为核心池中的线程设置存活时间,那么核心池中的线程空闲时间超过keepAliveTime,线程也会被终止
102
105
103
- # ** 4. 阻塞队列的介绍**
106
+ # 4. 阻塞队列的介绍
104
107
105
108
## 4.1 BlockingQueue
106
109
@@ -276,7 +279,8 @@ pool-1-thread-1 : 9
276
279
277
280
生产者生产任务,消费者消费任务,那么这时就需要一个任务队列,生产者向队列里插入任务,消费者从队列里提取任务执行
278
281
279
- # ** 5. 线程池工具类Executors**
282
+ # 5. 线程池工具类Executors
283
+
280
284
jdk1.5之后的一个新类,提供了一些静态工厂,生成一些常用的线程池,ThreadPoolExecutor是Executors类的底层实现
281
285
282
286
| 方法 | 功能描述 |
@@ -287,7 +291,8 @@ jdk1.5之后的一个新类,提供了一些静态工厂,生成一些常用
287
291
| newSingleThreadExecutor() | 创建单个线程的线程池,始终保证线程池中会有一个线程在。当某线程死去,会找继任者 |
288
292
| defaultThreadFactory() | 创建一个默认线程池工厂 |
289
293
290
- # ** 6. 线程池**
294
+ # 6. 线程池
295
+
291
296
在线程池的编程模式下,任务是提交给整个线程池,而不是直接交给某个线程,线程池在拿到任务后,它就在内部找有无空闲的线程,再把任务交给内部某个空闲的线程,这就是封装
292
297
293
298
记住:任务是提交给整个线程池,一个线程同时只能执行一个任务,但可以同时向一个线程池提交多个任务。
0 commit comments