Java 等待所有线程完成

Question

编辑：我的问题不同，它与链接的问题无关。

我使用完成处理程序跟踪代码。

FutureTask<Void> futureTask = new FutureTask<Void>(() -> {
    System.out.println("callback");
    return null;
});

Runnable task = () -> {
    for(int i=0; i<5; i++) {
        System.out.println(Thread.currentThread().getName() + " " + i);
    }
    futureTask.run();
};

new Thread(task).start();
new Thread(task).start();

基本上我正在寻找可变数量任务的完成处理程序，还是有其他方法？

我从这个answer 中得到启发，但在我寻找原生解决方案时，它似乎是某个库的一部分。

Completable Future???

这是我在最后使用结果处理程序的可完成期货的尝试。

public void test() {
    CompletableFuture
            .supplyAsync(() -> method1())
            .supplyAsync(() -> method2())
            .supplyAsync(() -> result());
}

public String method1() {
    System.out.println("calling 1");
    return "method1";
}

public String method2() {
    System.out.println("calling 2");
    return "method2";
}

public String result() {
    System.out.println("result");
    return "result";
}

Answer 1

假设您的方法 result() 返回一个您想要检索的值，即声明为 Type result()，您可以使用

CompletableFuture<Type> f = CompletableFuture.allOf(
    CompletableFuture.runAsync(() -> method1()),
    CompletableFuture.runAsync(() -> method2())
).thenApply(_void -> result());

每个runAsync 创建一个单独的异步CompletableFuture，一旦Runnable 执行完毕，该异步CompletableFuture 就会完成。和supplyAsync一样，只是不返回结果。

allOf 创建一个CompletableFuture，一旦所有指定的futures 完成，它就会完成，因此，任何链接的依赖动作只会在所有futures 都完成后运行。通过使用thenApply，我们创建了一个依赖未来，它将以result()的返回值完成。

如果result() 不打算返回一个值，而只是一个应该在所有其他操作完成后运行的操作，您可以使用

CompletableFuture.allOf(
    CompletableFuture.runAsync(() -> method1()),
    CompletableFuture.runAsync(() -> method2())
).thenRun(() -> result());

改为。

Answer 2

一种简单的方法是将您的 Runnable(s) 提交给 ExecutorService，然后调用 shutdown，然后调用 awaitTermination：

ExecutorService executor = Executors.newWorkStealingPool();
executor.submit(task);
executor.submit(task);

executor.shutdown();
executor.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);

无需使用 CompletableFuture。

Answer 3

根据您想要的控制程度，您可以使用 ThreadPoolExecutor：

tpe.execute(Runnable);

等待活动计数 == 0;

然后关闭执行器。

或者将线程保持在一个结构中。

等待特定的 TTL，如果状态为 RUNNABLE，则中断它们

Answer 4

保存指向您创建的线程的链接，然后调用join()

Thread a = new Thread(task);
Thread b = new Thread(task);
a.start();
b.start();

a.join();
b.join();
//guaranteed that both threads have completed here