java8 supplyasync_java – 为什么CompletableFuture.supplyAsync成功随...

我是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的参数提供的函数运行看似随机的次数？

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

java8 supplyasync_java – 为什么CompletableFuture.supplyAsync成功随...相关推荐

Java8 - 使用工厂方法 supplyAsync创建 CompletableFuture
文章目录 Pre 使用工厂方法 supplyAsync创建 CompletableFuture 对比 Pre Java8 - 使用CompletableFuture 构建异步应用目前为止我们已经了解 ...
CompletableFuture CompletableFuture.supplyAsync 异常处理
CompletableFuture CompletableFuture.supplyAsync 异常处理参考文章: (1)CompletableFuture CompletableFuture.su ...
Java8新特性--CompletableFuture
并发与并行 Java 5并发库主要关注于异步任务的处理,它采用了这样一种模式,producer线程创建任务并且利用阻塞队列将其传递给任务的consumer.这种模型在Java 7和8中进一步发展,并且 ...
java8 block_java8的CompletableFuture使用实例
thenApply(等待并转化future) @Test public void testThen() throws ExecutionException, InterruptedException ...
Java8新的异步编程方式 CompletableFuture(三)
前面两篇文章已经整理了CompletableFuture大部分的特性,本文会整理完CompletableFuture余下的特性,以及将它跟RxJava进行比较. 3.6 Either Either 表 ...
java8并行流_Java 8：CompletableFuture与并行流
java8并行流这篇文章展示了Java 8的CompletableFuture在执行异步计算时如何与并行流进行比较. 我们将使用以下类对长时间运行的任务进行建模: class MyTask {pri ...
Java8 提供CompletableFuture来简化高并发异步处理编程
(摘录自狂乱的贵公子)所谓异步调用其实就是实现一个可无需等待被调用函数的返回值而让操作继续运行的方法.在 Java 语言中,简单的讲就是另启一个线程来完成调用中的部分计算,使调用继续运行或返回,而不需 ...
【Java8新特性---＞异步处理】CompletableFuture
一.引入假设一个商品详情页需要以下操作: 查询展示商品的基本信息耗时:0.5s 查询展示商品的销售信息耗时:0.7s 查询展示商品的图片信息耗时:1s 查询展示商品销售属性耗时:0.3s 查询展示商 ...
《Java8实战》读书笔记10：组合式异步编程 CompletableFuture
<Java8实战>读书笔记10:组合式异步编程 CompletableFuture 第11章 CompletableFuture:组合式异步编程 11.1 Future 接口 (只是个引子 ...

java8 supplyasync_java – 为什么CompletableFuture.supplyAsync成功随...

java8 supplyasync_java – 为什么CompletableFuture.supplyAsync成功随...相关推荐

最新文章

热门文章