我是Java 8中lambda和异步代码的新手.我不断得到一些奇怪的结果……

我有以下代码：

import java.util.concurrent.CompletableFuture;

public class Program {

public static void main(String[] args) {

for (int i = 0; i < 100; i++) {

String test = "Test_" + i;

final int a = i;

CompletableFuture cf = CompletableFuture.supplyAsync(() -> doPost(test));

cf.thenRun(() -> System.out.println(a)) ;

}

}

private static boolean doPost(String t) {

System.out.println(t);

return true;

}

}

实际代码要长得多,因为doPost方法会将一些数据发布到Web服务.但是,我能用这个简单的代码复制我的问题.

我想让doPost方法执行100次,但出于性能原因而异步(为了将数据推送到Web服务比执行100次同步调用更快).

在上面的代码中,’doPost’方法是随机运行的,但总是不超过20-25次.没有例外.似乎某些线程处理机制默默地拒绝创建新线程并执行它们的代码,或者线程在没有崩溃程序的情况下静默崩溃.

我还有一个问题,如果我向doPost方法添加比上面显示的更多的功能,它会达到一个方法,该方法只是默默地破坏.在这种情况下,我尝试在return语句之前添加一个System.out.println(“test”),但它永远不会被调用.循环100次的循环确实运行了100次迭代.

至少可以说,这种行为令人困惑.

我错过了什么？为什么作为supplyAsync的参数提供的函数运行看似随机的次数？

编辑：只是想指出情况与问题中的情况不完全相同,因为这个问题涉及任意深度嵌套的期货,而这一问题涉及平行的问题.然而,他们失败的原因几乎完全相同.这些案件看起来很明显,值得向我提出不同的问题,但其他人可能不同意……