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

Question

>

我是Java多线程的新手。想知道线程池执行器中空闲线程的状态。它在RUNNABLE/WAITING中吗？

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

Answer 1

1. 很想知道ThreadPoolExecutor中空闲线程的状态。它是否处于可运行/等待状态

它将等待。它正在等待（在队列中。take（）调用）新任务出现在工作队列中。在当前的实现中，这涉及一种类似于等待/通知的机制。

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

然而，值得注意的是：

>

任何“空闲”线程都无法运行。

在当前一代的热点JVM中，实际的调度（决定哪些线程获得优先级并为它们分配一个内核来运行）由操作系统处理。

在Loom JVM（Loom仍然是一个孵化器项目）中，轻量级虚拟线程（“光纤”）由JVM而不是OS调度（到本机线程）。

Answer 2

很容易找到：

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)
...

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