Future.get 不能阻塞 forkjoinpool/workstealingpool 中的线程

Question

我把workstealingpool的大小设置为1，看来future.get()并没有阻塞线程。

@Test
public void runAsyncThenApplyExample() {
    ExecutorService executor = Executors.newWorkStealingPool(1);
    CompletableFuture cf = CompletableFuture.supplyAsync(
            () -> {
                //assertTrue(Thread.currentThread().isDaemon());
                System.out.println("func: " + threadName());
                Callable<Long> callable = () ->stub();
                Future<Long> future = executor.submit(callable);
                try {
                    future.get();  <<<<< **I think this should block the thread**
                } catch (InterruptedException | ExecutionException e) {
                    e.printStackTrace();
                }
                return 1;
            }, executor).thenAccept(s -> {
        System.out.println("accept: " + threadName());
    });
    //assertFalse(cf.isDone());
    System.out.println("main: " + threadName());
    sleep(10);
    assertTrue(cf.isDone());
}

private Long stub() {
    System.out.println("stub: " + threadName());
    return 1L;
}
private String threadName() {
    return Thread.currentThread().getName();
}

输出：

函数：ForkJoinPool-1-worker-3
主要：主要
存根：ForkJoinPool-1-worker-3
接受：ForkJoinPool-1-worker-3

Future.get() 和 stub 似乎使用的是同一个threead。

Answer 1

Executors.newWorkStealingPool(1); 使用 ForkJoinPool，它有一个未记录的功能，称为补偿线程。

来自http://www.coopsoft.com/ar/CalamityArticle.html（强调我的）：

JDK1.8 引入了 CompletableFuture 类。引用 JavaDoc：

“可以显式完成的 Future（设置其值和状态），并且可能包括在完成时触发的相关函数和操作。”

JavaDoc中没有提到的是，当使用带有get()方法的大量依赖函数时，框架会创建“补偿线程”以继续从deques和提交队列中获取应用程序任务.

因此，当您执行 future.get(); 时，它会阻塞，但会创建另一个线程来执行任务。

运行代码时，我得到的输出是：

函数：ForkJoinPool-1-worker-1
主要：主要
存根：ForkJoinPool-1-worker-0
接受：ForkJoinPool-1-worker-1

您还没有显示您的 threadName() 方法可能有错误，因此您看到相同的线程名称（或者您使用不同的 JVM 在这种情况下使用相同的名称，请检查线程ID）？如果不是，请提供将 func 和 stub 输出为相同线程的完整代码。

Answer 2

Future.get() 块，表示Future.get() 后面的代码在得到Result 之前不会执行。即使在您的输出中，您也可以看到存根首先完成执行。您可以尝试在您的退货声明之前在您的存根中放置 5 分钟左右的睡眠时间，看看会发生什么？