Java 8 CompletableFuture正在毫无必要地等待其他未来

Question

下面我有一个简单的代码。所有的期货都应该同时开始future13应该在Future1和Future3完成后立即运行，但在日志中我看到它会等到Future1、Future2、Future3和Future4全部完成后才运行。为什么要等到第二和第四期呢？

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

import org.junit.Test;


public class Test1 {

    private void loop(Long id, int max) {
        try {
            for (int i = 0; i < max; i++) {
                System.out.println(id);
                Thread.sleep(100);
            }
        } catch (Throwable t) {
            System.out.println(t);
        }
    }

    private CompletableFuture<Void> createConfigFuture(Long id) {
        return CompletableFuture.supplyAsync(() -> {
            loop(id, 100);
            return null;
        });
    }

    @Test
    public void testMe() {
        CompletableFuture<Void> future1 = createConfigFuture(1L);
        CompletableFuture<Void> future2 = createConfigFuture(2L);
        CompletableFuture<Void> future3 = createConfigFuture(3L);
        CompletableFuture<Void> future4 = createConfigFuture(4L);

        try {
            CompletableFuture<Void> future13 = CompletableFuture.allOf(future1, future3)
                .thenApply(v -> {
                    loop(999L, 5);
                    return null;
                });
            CompletableFuture<Void> mainFuture = CompletableFuture.allOf(future13, future2, future4);
            mainFuture.get();

        } catch (InterruptedException | ExecutionException e) {
            System.out.println(e);
        }
    }
}

Answer 1

在JRE的默认fork joinExecutor中有一个队列来获取执行槽，所有异步任务都将在该执行槽上序列化。

任务#2在该执行者队列中位于任务#3之前，因此在观察任务#3的执行（以及完成任务#13的执行）之前，#2应该首先获得其执行槽。

这可能被视为链接到#2的#3，但除此之外，任务之间不应存在任何额外的耦合。