文章目录

Pre
避免同步阻塞的困扰
- V1.0 改进 -采用Stream 顺序查询（不理想）
- V2.0 改进 - 使用并行流对请求进行并行操作（good）
- V3.0 改进 - 使用 CompletableFuture发起异步请求（）
更好的方案

Pre

Java8 - 使用工厂方法 supplyAsync创建 CompletableFuture

接着上面的例子

假设非常不幸，无法控制 Shop 类提供API的具体实现，最终提供给你的API都是同步阻塞式的方法。这也是当你试图使用服务提供的HTTP API时最常发生的情况。你会学到如何以异步的方式查询多个商店，避免被单一的请求所阻塞，并由此提升你的“最佳价格查询器”的性能和吞吐量。

避免同步阻塞的困扰

假设你需要查询的所有商店只提供了同步API，换句话说，你有一个商家的列表，如下所示：

List<Shop> shops = Arrays.asList(new Shop("BestPrice"),new Shop("LetsSaveBig"),new Shop("MyFavoriteShop"),new Shop("BuyItAll"));

你需要使用下面这样的签名实现一个方法，它接受产品名作为参数，返回一个字符串列表，这个字符串列表中包括商店的名称、该商店中指定商品的价格：

public List<String> findPrices(String product);

V1.0 改进 -采用Stream 顺序查询（不理想）

第一个想法可能是使用 Stream 特性。

【采用顺序查询所有商店的方式实现的 findPrices 方法】

public List<String> findPrices(String product) {return shops.stream().map(shop -> String.format("%s price is %.2f",shop.getName(), shop.getPrice(product))).collect(toList());
}

好吧，这段代码看起来非常直白。此外，也请记录下方法的执行时间，通过这
些数据，我们可以比较优化之后的方法会带来多大的性能提升，具体的代码清单如下。

【验证 findPrices 的正确性和执行性能】

long start = System.nanoTime();
System.out.println(findPrices("myPhone27S"));
long duration = (System.nanoTime() - start) / 1_000_000;
System.out.println("Done in " + duration + " msecs");

输出

[BestPrice price is 123.26, LetsSaveBig price is 169.47, MyFavoriteShop price
is 214.13, BuyItAll price is 184.74]
Done in 4032 msecs

正如你预期的， findPrices 方法的执行时间4S+，因为对这4个商店的查询是顺序进行的，并且一个查询操作会阻塞另一个，每一个操作都要花费大于1S的时间计算请求商品的价格。

怎样才能改进这个结果呢？

V2.0 改进 - 使用并行流对请求进行并行操作（good）

对V1.0改成并行试试？

【对 findPrices 进行并行操作】

public List<String> findPrices(String product) {return shops.parallelStream().map(shop -> String.format("%s price is %.2f", shop.getName(), shop.getPrice(product))).collect(toList());
}

区别在于 parallelStream ，使用并行流并行流从不同的商店获取价格。

运行代码，与V·1.0的执行结果相比较，发现了新版 findPrices 的改进了吧。

[BestPrice price is 123.26, LetsSaveBig price is 169.47, MyFavoriteShop price
is 214.13, BuyItAll price is 184.74]
Done in 1180 msecs

相当不错啊！看起来这是个简单但有效的主意：现在对四个不同商店的查询实现了并行，所以完成所有操作的总耗时只有1S多一点儿。

还能能做得更好吗？要不试试CompletableFuture ，将 findPrices 方法中对不同商店的同步调用替换为异步调用。

V3.0 改进 - 使用 CompletableFuture发起异步请求（）

我们可以使用工厂方法 supplyAsync 创建 CompletableFuture 对象。让我们把它利用起来：

List<CompletableFuture<String>> priceFutures =shops.stream().map(shop -> CompletableFuture.supplyAsync(() -> String.format("%s price is %.2f",shop.getName(), shop.getPrice(product)))).collect(toList());

使用这种方式，你会得到一个 List<CompletableFuture<String>> ，列表中的每个CompletableFuture 对象在计算完成后都包含商店的 String 类型的名称。但是，由于你用CompletableFutures 实现的 findPrices 方法要求返回一个 List<String> ，你需要等待所有的 future 执行完毕，将其包含的值抽取出来，填充到列表中才能返回

为了实现这个效果，你可以向最初的 List<CompletableFuture<String>> 添加第二个map 操作，对 List 中的所有 future 对象执行 join 操作，一个接一个地等待它们运行结束。

Note: CompletableFuture 类中的 join 方法和 Future 接口中的 get 有相同的含义，并且也声明在Future 接口中，它们唯一的不同是 join 不会抛出任何检测到的异常。使用它你不再需要使用try / catch 语句块让你传递给第二个 map 方法的Lambda表达式变得过于臃肿。

所有这些整合在一起，你就可以重新实现 findPrices 了，具体代码如下

public List<String> findPrices(String product) {List<CompletableFuture<String>> priceFutures =shops.stream().map(shop -> CompletableFuture.supplyAsync(() -> shop.getName() + " price is " +shop.getPrice(product))).collect(Collectors.toList());
return priceFutures.stream().map(CompletableFuture::join).collect(toList());
}

注意到了吗？这里使用了两个不同的 Stream 流水线，而不是在同一个处理流的流水线上一个接一个地放两个 map 操作——这其实是有缘由的。

考虑流操作之间的延迟特性，如果你在单一流水线中处理流，发向不同商家的请求只能以同步、顺序执行的方式才会成功。因此，每个创建 CompletableFuture 对象只能在前一个操作结束之后执行查询指定商家的动作、通知 join方法返回计算结果。

【为什么 Stream 的延迟特性会引起顺序执行，以及如何避免】见下图

上半部分展示了使用单一流水线处理流的过程，我们看到，执行的流程（以虚线标识）是顺序的。事实上，新的 CompletableFuture 对象只有在前一个操作完全结束之后，才能创建。与此相反，图的下半部分展示了如何先将 CompletableFutures 对象聚集到一个列表中（即图中以椭圆表示的部分），让对象们可以在等待其他对象完成操作之前就能启动。

运行代码第三个版本 findPrices 方法的性能，你会得到下面这几行输出：

[BestPrice price is 123.26, LetsSaveBig price is 169.47, MyFavoriteShop price
is 214.13, BuyItAll price is 184.74]
Done in 2005 msecs

超过2S意味着利用 CompletableFuture 实现的版本比刚开始原生顺序执行且会发生阻塞的版本快。但是它的用时也差不多是使用并行流的前一个版本的两倍。尤其是，考虑到从顺序执行的版本转换到并行流的版本只做了非常小的改动，就让人更加沮丧

与此形成鲜明对比的是，我们为采用 CompletableFutures 完成的新版方法做了大量的工作！

但，这就是全部的真相吗？这种场景下使用 CompletableFutures 真的是浪费时间吗？或者我们可能漏了某些重要的东西？

更好的方案

并行流的版本工作得非常好，那是因为它能并行地执行四个任务，所以它几乎能为每个商家分配一个线程。但是，如果你想要增加第五个商家到商点列表中，让你的“最佳价格查询”应用

Java8 - 避免代码阻塞的骚操作相关推荐

【C语言】那些优秀代码里的骚操作（持续更新…）
[C语言]那些优秀代码里的骚操作(持续更新-) 1.联合体`union`的妙用 2.`#include`的本质是什么? 3.脱裤子放屁的`do{ }while(0)` 4.一个成熟的代码要学会自己写函 ...
逆向趣事：那些封印在代码中的骚操作
在逆向一些正常或恶意软件时,有时会遇到一些作者封印在代码中的骚操作,有趣又另类,甚至可以作为检测规则来应用,今天就来聊聊这些骚操作. 01 - 闲趣型 2012年的时候,Fireye捕获到一个Java ...
python一两行代码完成的骚操作
分享一个实用问题,用python读取Excel并保存字典,如何做? 下面是该同学问题截图和代码代码截图是下面这样的不知道大家第一眼看了这个代码,什么感受?我第一眼的感受是密密麻麻一大堆,读都不想读 ...
关机的代码和电脑骚操作
关机的代码 shutdown.exe -a 取消关机 shutdown.exe -f 强行关闭应用程序. shutdown.exe -m \计算机名控制远程计算机. shutdown.exe -i ...
java putifabsent_java8中Map的一些骚操作总结
一前言本篇内容是关于 map 新特性的一些方法使用上的介绍,如果有不足之处欢迎补充!! 二 map新特性关于以下函数式编程的函数的计算知识追寻者都使用简单字符串代替了,参数无非就是Key,va ...
Python骚操作：Python控制Excel实现自动化办公！
Python骚操作:Python控制Excel实现自动化办公! 1.安装 Python骚操作:Python控制Excel实现自动化办公! 2.操作一个简单的Excel文档操作注释及代码: Pytho ...
【Python基础】pandas的骚操作：一行 pandas 代码搞定 Excel “条件格式”！
来源:Python数据科学作者:东哥起飞本篇是pandas100个骚操作系列的第 7 篇:一行 pandas 代码搞定 Excel "条件格式"! 系列内容,请看????「pa ...
骚操作，IDEA防止写代码沉迷插件 !
当初年少懵懂,那年夏天填志愿选专业,父母听其他长辈说选择计算机专业好.从那以后,我的身上就有了计院深深的烙印.从寝室到机房,从机房到图书馆,C.C++.Java.只要是想写点自己感兴趣的东西,一坐就是 ...
CSS骚操作之表单验证功能的实现代码
CSS骚操作之表单验证功能的实现代码效果图如下: 原理: 表单元素中,有一个pattern属性,可以自定义正则表达式(如手机号.邮箱.身份证-):valid伪类,可以匹配通过pattern验证的元 ...

Java8 - 避免代码阻塞的骚操作

文章目录

Pre

避免同步阻塞的困扰

V1.0 改进 -采用Stream 顺序查询（不理想）

V2.0 改进 - 使用并行流对请求进行并行操作（good）

V3.0 改进 - 使用 CompletableFuture发起异步请求（）

更好的方案

Java8 - 避免代码阻塞的骚操作相关推荐

最新文章

热门文章

Java8 - 避免代码阻塞的骚操作

文章目录

Pre

避免同步阻塞的困扰

V1.0 改进 -采用Stream 顺序查询 （不理想）

V2.0 改进 - 使用并行流对请求进行并行操作 （good）

V3.0 改进 - 使用 CompletableFuture发起异步请求 （）

更好的方案

Java8 - 避免代码阻塞的骚操作相关推荐

最新文章

热门文章

V1.0 改进 -采用Stream 顺序查询（不理想）

V2.0 改进 - 使用并行流对请求进行并行操作（good）

V3.0 改进 - 使用 CompletableFuture发起异步请求（）