我是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的参数提供的函数运行看似随机的次数?
编辑:只是想指出情况与问题中的情况不完全相同,因为这个问题涉及任意深度嵌套的期货,而这一问题涉及平行的问题.然而,他们失败的原因几乎完全相同.这些案件看起来很明显,值得向我提出不同的问题,但其他人可能不同意……