java - 在Java中是否存在从List <CompletionStage>到CompletionStage <List>的转换器？

就像在使用of的假设示例中一样：

List<CompletionStage<Long>> listOfFutureLongs = getFutureLongs(...)
CompletionStage<List<Long>> futureListOfLongs = CompletionStage.of(listOfFutureLongs)

最佳答案

奇怪的是

CompletableFuture.allOf有CompletableFuture，有点像您想要的，但CompletionStage没有类似的功能。

您可以使用CompletionStage.toCompletableFuture获取期货，也可以编写自己的期货。

不幸的是，无法检查CompletionStage是否已完成表示您无法高效地执行此操作。

该代码在我的一个尚未发布（也尚未测试）的开源项目中。随意使用它：

public static <T> CompletionStage<List<T>> list(List<CompletionStage<T>> list)
{
    if (list.size() <= 0)
    {
        return CompletableFuture.completedFuture(Collections.emptyList());
    }
    if (list.size() == 1)
    {
        return list.get(0).thenApply(Collections::singletonList);
    }
    final AtomicInteger waiters = new AtomicInteger(1);
    final List<T> ret = new ArrayList<>(list.size());
    final AtomicReference<Throwable> retErr = new AtomicReference<>();
    final CompletableFuture<List<T>> retFuture = new CompletableFuture<>();
    for (int i = 0; i < list.size(); ++i)
    {
        ret.add(null);
        final int pos = i;
        final CompletionStage<T> cs = list.get(i);
        if (cs == null)
        {
            continue;
        }
        waiters.incrementAndGet();
        cs.whenComplete((val, err) -> {
            if (err != null)
            {
                retErr.compareAndSet(null, err);
            }
            ret.set(pos, val);
            _doneListItem(waiters, retFuture, ret, retErr.get());
        });
    }
    _doneListItem(waiters, retFuture, ret, retErr.get());
    return retFuture;
}

private static <T> void _doneListItem(AtomicInteger waitCount, CompletableFuture<List<T>> ret, List<T> val, Throwable err)
{
    if (waitCount.decrementAndGet() == 0)
    {
        if (err != null)
        {
            ret.completeExceptionally(err);
        }
        else
        {
            ret.complete(val);
        }
    }
}

关于java - 在Java中是否存在从List <CompletionStage>到CompletionStage <List>的转换器？，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/56135121/