Skip to content

Commit 4d833d3

Browse files
committed
[docs update]核心线程空闲时状态
1 parent d11cfa5 commit 4d833d3

File tree

1 file changed

+61
-0
lines changed

1 file changed

+61
-0
lines changed

docs/java/concurrent/java-concurrent-questions-03.md

Lines changed: 61 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -361,6 +361,67 @@ public void allowCoreThreadTimeOut(boolean value) {
361361
}
362362
```
363363

364+
### 核心线程空闲时处于什么状态?
365+
366+
核心线程空闲时,其状态分为以下两种情况:
367+
368+
- **设置了核心线程的存活时间** :核心线程在空闲时,会处于阻塞状态,等待获取任务。如果阻塞等待的时间超过了核心线程存活时间,则该核心线程会被销毁。
369+
- **没有设置核心线程的存活时间** :核心线程在空闲时,会一直处于阻塞状态,等待获取任务。
370+
371+
#### 相关源码
372+
373+
接下来通过相关源码,了解一下线程池内部是如何做的。
374+
375+
线程在线程池内部被抽象为了 `Worker` ,当 `Worker` 被启动之后,会不断去任务队列中获取任务。
376+
377+
在获取任务的时候,会根据 `timed` 值来决定从任务队列( `BlockingQueue` )获取任务的行为。
378+
379+
如果「设置了核心线程的存活时间」或者「线程数量超过了核心线程数量」,则将 `timed` 标记为 `true`
380+
381+
- `timed == true` :使用 `poll()` 来获取任务。`poll()` 方法会指定获取任务的等待时间,如果到达等待时间之后,还没有获取到任务,则会返回 `null`
382+
- `timed == false` :使用 `take()` 来获取任务。`take()` 方法是 `BlockingQueue` 中的阻塞方法,调用之后,线程会进入等待状态,直到从队列中获取任务。
383+
384+
因此,如果「设置了核心线程的存活时间」,核心线程没有在超时时间之内获取到任务,则会被销毁。
385+
386+
如果「没有设置核心线程的存活时间」,则核心线程在没有获取到任务时,会通过 `take()` 方法进行阻塞等待。
387+
388+
源码如下:
389+
390+
```JAVA
391+
// ThreadPoolExecutor
392+
private Runnable getTask() {
393+
boolean timedOut = false;
394+
for (;;) {
395+
// ...
396+
397+
// 1、如果「设置了核心线程的存活时间」或者是「线程数量超过了核心线程数量」,则 timed 为 true。
398+
boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;
399+
// 2、扣减线程数量。
400+
// wc > maximuimPoolSize:线程池中的线程数量超过最大线程数量。其中 wc 为线程池中的线程数量。
401+
// timed && timeOut:timeOut 表示获取任务超时。
402+
// 分为两种情况:核心线程设置了存活时间 && 获取任务超时,则扣减线程数量;线程数量超过了核心线程数量 && 获取任务超时,则扣减线程数量。
403+
if ((wc > maximumPoolSize || (timed && timedOut))
404+
&& (wc > 1 || workQueue.isEmpty())) {
405+
if (compareAndDecrementWorkerCount(c))
406+
return null;
407+
continue;
408+
}
409+
try {
410+
// 3、如果 timed 为 true,则使用 poll() 获取任务;否则,使用 take() 获取任务。
411+
Runnable r = timed ?
412+
workQueue.poll(keepAliveTime, TimeUnit.NANOSECONDS) :
413+
workQueue.take();
414+
// 4、获取任务之后返回。
415+
if (r != null)
416+
return r;
417+
timedOut = true;
418+
} catch (InterruptedException retry) {
419+
timedOut = false;
420+
}
421+
}
422+
}
423+
```
424+
364425
### ⭐️线程池的拒绝策略有哪些?
365426

366427
如果当前同时运行的线程数量达到最大线程数量并且队列也已经被放满了任务时,`ThreadPoolExecutor` 定义一些策略:

0 commit comments

Comments
 (0)