【发布时间】：2013-12-05 20:18:58
【问题描述】：
我正在使用 Java 8 中的 CompletableFuture 和流，每次运行时都会得到不同的打印输出。只是好奇，为什么？
public class DoIt {
public static class My {
private long cur = 0;
public long next() {
return cur++;
}
}
public static long add() {
long sum = 0;
for (long i=0; i<=100;i++) {
sum += i;
}
return sum;
}
public static long getResult(CompletableFuture<Long> f) {
long l = 0;
try {
f.complete(42l);
l = f.get();
System.out.println(l);
} catch (Exception e) {
//...
}
return l;
}
public static void main(String[] args){
ExecutorService exec = Executors.newFixedThreadPool(2);
My my = new My();
long sum = Stream.generate(my::next).limit(20000).
map(x -> CompletableFuture.supplyAsync(()-> add(), exec)).
mapToLong(f->getResult(f)).sum();
System.out.println(sum);
exec.shutdown();
}
}
如果我跳过 f.complete(42l) 调用，我总是会得到相同的结果。
【问题讨论】：
-
@guido，请搜索现有标签而不是创建新标签。我们已经有一个标签来涵盖 Java 8 Stream API。
-
@Charles 抱歉，Charles，我确实搜索了一个，但没想到 java- 前缀，感谢您的编辑。我现在也找到了streams-ap i（看起来拼写错误）我会在meta上搜索
标签： java-8 java-stream