您是否必须加入线程以确保其计算完成

Question

我有一个实用程序方法（用于单元测试，它确实发生了），它Runnable在另一个线程中执行一个。它启动线程运行，但不等待Thread结束，而是依靠Future。该方法的调用者可能希望get()这样做Future。但这足以确保安全地发布由Runnable？完成的计算吗？

方法如下：

private static Future<Void> runInOtherThread(final CountDownLatch ready, final Runnable operation) {
    final CompletableFuture<Void> future = new CompletableFuture<Void>();
    final Thread thread = new Thread(() -> {
        try {
            ready.await();
            operation.run();
        } catch (Throwable e) {
            future.completeExceptionally(e);
            return;
        }
        future.complete(null);
    });
    thread.start();
    return future;
}

调用Future.get()返回Future的方法后，方法的调用者是否可以安全地假定方法Runnable已完成执行，并且其结果已安全发布？

Answer 1

不，你不需要join()。呼吁get()未来就足够了。

该CompletableFuture接口是的子类型Future。和javadoc中的Future状态是：

内存一致性影响：异步计算采取的操作 发生Future.get()在另一个线程中相应操作之后的操作 之前 。

这种先 发生后 关系足以确保安全地发布所返回的值get()。

此外，get()呼叫CompletableFuture必须在完成，异常完成或取消后才能完成。