完全的未来。anyOf-所用语言需要帮助

Question

我需要一些关于anyOf javadoc将来使用的文献的帮助。

<代码>静态CompletableFuture

这个“相同的结果”是什么意思？与什么相同？与CompletableFuture数组中的任何其他未来相同？

谢谢Venkatesh Laguduva

Answer 1

同一系列可完成的未来中的任何其他未来一样？

确实如此。

一旦数组var-args的任何CompletableFutures完成，该方法就会返回一个具有相同结果的新CompletableFuture对象。

如果您查看实现，您可以获得确认。

public static CompletableFuture<Object> anyOf(CompletableFuture<?>... cfs) {
    return orTree(cfs, 0, cfs.length - 1);
}

调用orTree（）：

static CompletableFuture<Object> orTree(CompletableFuture<?>[] cfs,
                                        int lo, int hi) {
    CompletableFuture<Object> d = new CompletableFuture<Object>();
    if (lo <= hi) {
        CompletableFuture<?> a, b;
        int mid = (lo + hi) >>> 1;
        if ((a = (lo == mid ? cfs[lo] :
                  orTree(cfs, lo, mid))) == null ||
            (b = (lo == hi ? a : (hi == mid+1) ? cfs[hi] :
                  orTree(cfs, mid+1, hi)))  == null)
            throw new NullPointerException();
        if (!d.orRelay(a, b)) {
            OrRelay<?,?> c = new OrRelay<>(d, a, b);
            a.orpush(b, c);
            c.tryFire(SYNC);
        }
    }
    return d;
}

Answer 2

当它说相同的结果时，它意味着与第一个完成的未来相同的结果。

如果您使用以下内容：

CompletableFuture<String> stringFuture = CompletableFuture.supplyAsync(() -> {
    Thread.sleep(3000); // handle exc
    return "String";
});

CompletableFuture<Integer> intFuture = CompletableFuture.supplyAsync(() -> {
    Thread.sleep(4000); // handle exc
    return 1;
});

结果将与第一个完成的未来相同，如果字符串首先完成，则对象将是具有该未来值的字符串类型，依此类推。

在这种情况下：

CompletableFuture.anyOf(stringFuture, intFuture).get()

将返回"string"，因为它首先完成，如果intFuture首先完成，它将返回1；