技术编程5万字：Stream和Lambda表达式最佳实践2( 九 ) |

看下输出结果：INFO com.flydean.InfiniteStreamUsage - [IntegerWrapper(integer=46), IntegerWrapper(integer=42), IntegerWrapper(integer=67), IntegerWrapper(integer=11), IntegerWrapper(integer=14), IntegerWrapper(integer=80), IntegerWrapper(integer=15), IntegerWrapper(integer=19), IntegerWrapper(integer=72), IntegerWrapper(integer=41)]复制代码16. 自定义parallelStream的thread pool
之前我们讲到parallelStream的底层使用到了ForkJoinPool来提交任务的，默认情况下ForkJoinPool为每一个处理器创建一个线程， parallelStream如果没有特别指明的情况下，都会使用这个共享线程池来提交任务。
那么在特定的情况下，我们想使用自定义的ForkJoinPool该怎么处理呢？16.1 通常操作
假如我们想做一个从1到1000的加法，我们可以用并行stream这样做：List
integerList= IntStream.range(1,1000).boxed().collect(Collectors.toList());ForkJoinPool customThreadPool = new ForkJoinPool(4);Integer total= integerList.parallelStream().reduce(0, Integer::sum);log.info("{}",total);复制代码
输出结果：INFO com.flydean.CustThreadPool - 499500复制代码16.2 使用自定义ForkJoinPool
上面的例子使用的共享的thread pool 。我们看下怎么使用自定义的thread pool来提交并行stream：List
integerList= IntStream.range(1,1000).boxed().collect(Collectors.toList());ForkJoinPool customThreadPool = new ForkJoinPool(4);Integer actualTotal = customThreadPool.submit(() -> integerList.parallelStream().reduce(0, Integer::sum)).get();log.info("{}",actualTotal);复制代码
上面的例子中，我们定义了一个4个线程的ForkJoinPool ，并使用它来提交了这个parallelStream 。
输出结果：INFO com.flydean.CustThreadPool - 499500复制代码
如果不想使用公共的线程池，则可以使用自定义的ForkJoinPool来提交。 17. 总结
本文统一介绍了Stream和lambda表达式的使用，涵盖了Stream和lambda表达式的各个小的细节，希望大家能够喜欢。

技术编程5万字：Stream和Lambda表达式最佳实践2( 九 )

推荐阅读

蹲下为你系鞋带|以前最发达，现在却最差！，金砖国家中混得最可怜的国家

黄河新闻网吕梁频道|柳林交警持续开展文明交通进驾校安全宣传活动

：客厅装修要注意这些地方，尤其是第三个，聪明人都避开！

联想电脑怎么更新显卡驱动

一个鹌鹑蛋多少克鹌鹑蛋一个多少克

穿搭|37岁田馥甄老太快！近照身材苗条脸却变大，脸不对称笑容太僵硬

加入抗癌公社有啥好处

磊子|一定是真爱，那个冒雨为你撑伞的男人

纤的拼音和组词纤的拼音

三八妇女节讲话稿三八妇女节演讲稿

苹果代工厂欠薪事件后续，纬创总裁被开除，工人投诉热线被打爆

海纳新闻|CNN不留情面：种族主义，无计可施了？特朗普又打起“中国牌”

穿衣搭配|不懂就问，男明星像罗云熙这么“瘦”，真的好看吗？

咸蛋小姐|超模身材就是不一样，贝拉·哈迪德和海莉同穿紧身短裤秀身材

每天喝二两白酒真可以防治新冠肺炎吗？

智通财经||美股区块链概念股大跌，中网载线(CNET.US)跌超8%，美股异动

外出@湖北武穴抓住外出闲逛人员要考黄冈密卷？假的！

「42号车库」电动化平台：战争真正开始的信号

荣耀30系列有哪些优势？

汽车|蔚来今年股价暴涨十倍，沽空机构香橼唱空，造车新势力高台跳水