Java 多线程 - 空闲线程的状态

Question

1. 我是 Java 多线程的新手。想知道 ThreadPoolExecutor 的空闲线程的状态。是否处于 RUNNABLE/WAITING 状态？

2. 如果空闲线程处于 RUNNABLE 状态，新任务如何附加到空闲线程？ AFAIK 我们将一个可运行/可调用对象分配给线程/池。但我的问题是 ThreadPoolExecutor 如何将排队的可运行对象分配给空闲线程？？

Answer 1

很容易找到：

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.io.IOException;

public class ThreadExample {

    public static void main(String[] args) throws IOException {
        Executor executor = Executors.newFixedThreadPool(5);
        // force the threads to be started
        for (int i = 0; i < 5; i++) {
            executor.execute(() -> {
                try {Thread.sleep(1000);} catch (InterruptedException e) {
                }
            });
        }
        // don't terminate
        System.in.read();
    }
}

运行它：

$ javac ThreadExample.java
$ java ThreadExample

在另一个控制台中，等待至少一秒钟以完成任务：

$ ps
  PID TTY           TIME CMD
 3640 ttys000    0:00.25 -bash
 5792 ttys000    0:00.15 java ThreadExample
 5842 ttys001    0:00.05 -bash
$ jstack 5792
...
"pool-1-thread-1" #12 prio=5 os_prio=31 cpu=1.77ms elapsed=13.37s tid=0x00007fe99f833800 nid=0xa203 waiting on condition  [0x00007000094b2000]
   java.lang.Thread.State: WAITING (parking)
    at jdk.internal.misc.Unsafe.park(java.base@11.0.2/Native Method)
    - parking to wait for  <0x000000061ff9e998> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
    at java.util.concurrent.locks.LockSupport.park(java.base@11.0.2/LockSupport.java:194)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@11.0.2/AbstractQueuedSynchronizer.java:2081)
    at java.util.concurrent.LinkedBlockingQueue.take(java.base@11.0.2/LinkedBlockingQueue.java:433)
    at java.util.concurrent.ThreadPoolExecutor.getTask(java.base@11.0.2/ThreadPoolExecutor.java:1054)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(java.base@11.0.2/ThreadPoolExecutor.java:1114)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(java.base@11.0.2/ThreadPoolExecutor.java:628)
    at java.lang.Thread.run(java.base@11.0.2/Thread.java:834)
...

所有池线程都处于该状态。

Answer 2

1. 想知道在 ThreadPoolExecutor 的情况下空闲线程的状态。是否处于 RUNNABLE/WAITING 状态？

它将等待。它正在等待（在Queue.take() 调用中）新任务出现在工作队列中。在当前的实现中，这涉及到类似于wait / notify 的机制。

因此，您的第二个问题没有实际意义。

但是，值得注意的是：

1. 永远不会有“空闲”线程可以运行。

2. 在当前一代的 HotSpot JVM 中，实际的调度（决定哪些线程获得优先级并分配它们运行的​​核心）由操作系统处理。

3. 在 Loom JVM 中（Loom 仍然是一个孵化器项目），轻量级 virtual threads（“纤维”）由 JVM 而非操作系统调度（到本机线程）。