java - 为什么 java ExecutorService execute 接受一个新的 Runnable 实现

Question

在下面的给定片段中:

private ExecutorService executor = Executors.newFixedThreadPool(2); //create a fixed thread pool

executor.execute(new Thread(() -> foo()));
executor.execute(new Thread(() -> foo()));
executor.execute(new Thread(() -> foo()));

在上面的例子中创建了多少个线程 2 或 3？

• 2:因为执行器池大小为2。
• 3:在代码中，我执行了 3 次 new Thread。

为什么不 executor.execute(Callable); ？

Answer 1

从根本上说:不要将 Thread 与 execute 一起使用, 使用 Runnable。如您所述，处理线程是 ExecutorService 的工作。

In the above example how many threads are created 2 or 3?

您已在评论中阐明您指的是操作系统线程。

两个或五个(完整的线程或纤维)。几乎可以肯定不是三个。可以是一个或四个。不错的准确答案。 :-) 这是推理:

当您明确地这样做时，肯定会创建三个 Thread 实例。这并不意味着因此创建了三个操作系统线程。 Thread 的 JavaDoc 没有明确说明操作系统线程是在创建 Thread 对象时或稍后/如果调用 start 时创建的，这很可能取决于实现。由于您从不调用 start，我们不知道是否为这些 Thread 实例创建了任何操作系统线程。

所以就操作系统线程而言，它可能是:

• 只有一两个，由 ExecutorService 创建并启动，以响应您调用 execute 两次或更多次以及创建服务时设置的限制是两个线程。最初我假设它肯定会在这三个调用的情况下创建两个线程，但是 Aleksandr Semyannikov在 a comment 中指出ExecutorService 可能不必创建两个线程。由那些 execute 调用安排的工作只是一个方法调用(尽管我们不知道该方法需要多长时间才能运行)。所以它可能只能重用一个线程。我倾向于怀疑它(我认为第一个线程仍将分配给第一个 execute 调用，当你进行第二个调用时)，但我对此的信心水平不超过 60%。 :-) 如果它真的很重要，我会对其进行测试(尽管我不太确定如何测试它)。
• 四个或五个:三个由 new Thread 创建，一两个由 ExecutorService 创建并启动。

我的钱是两个。

我想我们可以排除三个。要得到答案三，ExecutorService 实现必须使用您传递给它的线程，而它几乎肯定不会。

---

在我的 Linux 系统上，我可以确认我的 Java 版本从 15 (!) 个线程开始，当上面的代码运行时，又创建了两个。我还可以确认这些线程是池线程，而不是来自 new Thread 的线程。我使用了这个即兴代码:

import java.util.*;
import java.util.concurrent.*;

public class Example {
    private static void foo() {
        System.out.println(Thread.currentThread().getName());
    }
    public static void main(String[] args) throws Exception {
        System.out.println("Waiting...");
        Thread.currentThread().sleep(20000);
        System.out.println("Starting...");
        ExecutorService executor = Executors.newFixedThreadPool(2); //create a fixed thread pool

        executor.execute(new Thread(() -> foo()));
        executor.execute(new Thread(() -> foo()));
        executor.execute(new Thread(() -> foo()));
    }
}

并且在 20 年代等待期间使用了 ps aux | grep java 获取进程的 PID，top -H -pPID(其中 PID 是 pid)查看线程。