很多同学喜欢使用lambda表达式，它允许你定义短小精悍的函数，体现你高超的编码水平。当然，这个功能在某些以代码行数来衡量工作量的公司来说，就比较吃亏一些。

比如下面的代码片段，让人阅读的时候就像是读诗一样。但是一旦用不好，也是会要命的。

ListIntegertransactionsIds=widgets.stream().filter(b-b.getColor()==RED).sorted((x,y)-x.getWeight()-y.getWeight()).mapToInt(Widget::getWeight).sum();这段代码有一个关键的函数，那就是stream。通过它，可以将一个普通的list，转化为流，然后就可以使用类似于管道的方式对list进行操作。总之，用过的都说好。

对这些函数还不是太熟悉？可以参考：《到处是map、flatMap，啥意思？》

问题来了

假如我们把stream换成parallelStream，会发生什么情况？

根据字面上的意思，流会从串行变成并行。

既然是并行，那用屁股想一想，就知道这里面肯定会有线程安全问题。不过我们这里讨论的并不是要你使用线程安全的集合，这个话题太低级。现阶段，知道在线程不安全的环境中使用线程安全的集合，已经是一个基本的技能。

这次踩坑的地方，是并行流的性能问题。

我们用代码来说话。

下面的代码，开启了8个线程，这8个线程都在使用并行流进行数据计算。在执行的逻辑中，我们让每个任务都sleep1秒钟，这样就能够模拟一些I/O请求的耗时等待。

使用stream，程序会在30秒后返回，但我们期望程序能够在1秒多返回，因为它是并行流，得对得起这个称号。

测试发现，我们等了好久，任务才执行完毕。

staticvoidparalleTest(){ListIntegernumbers=Arrays.asList(0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29);finallongbegin=System.currentTimeMillis();numbers.parallelStream().map(k-{try{Thread.sleep();System.out.println((System.currentTimeMillis()-begin)+ms=+k+\t+Thread.currentThread());}catch(InterruptedExceptione){e.printStackTrace();}returnk;}).collect(Collectors.toList());}publicstaticvoidmain(String[]args){//System.setProperty(java.util.concurrent.ForkJoinPool.

转载请注明:http://www.aideyishus.com/lkyy/3374.html