博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java 集合使用parallelStream 和 stream的问题
阅读量:5880 次
发布时间:2019-06-19

本文共 1483 字,大约阅读时间需要 4 分钟。

hot3.png

使用parallelStream代码

public static void main(String[] args) {        List
ids1 = Lists.newArrayList(); List
ids2 = Lists.newArrayList(); for(int i = 0; i < 1000; i ++){ ids1.add(i); } ids1.parallelStream().forEach(id ->ids2.add(id)); }

结果:

Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: 823	at java.util.ArrayList.add(ArrayList.java:459)	at com.test.lambda$main$0(Md5Util.java:51)	at com.test$$Lambda$1/399573350.accept(Unknown Source)	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1374)	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:512)	at java.util.stream.ForEachOps$ForEachTask.compute(ForEachOps.java:290)	at java.util.concurrent.CountedCompleter.exec(CountedCompleter.java:731)	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:902)	at java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1689)	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1644)	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)

因为parallelStream是并发流,当使用线程不安全的list的时候可能导致数组越界,可以使用线程安全的list,如下所示

List
ids2 = Collections.synchronizedList(Lists.newArrayList());

如果使用 stream()方法,单线程处理也可以

转载于:https://my.oschina.net/u/3337958/blog/1922236

你可能感兴趣的文章
分享10个帮助你实现超酷特效的jQuery插件
查看>>
atm仿真脚本
查看>>
11套免费的wordpress模板主题
查看>>
Facebook 新闻(Facebook Journalism)
查看>>
解除apt-get被占用
查看>>
PHP Smarty 模板 读取配置文件变量
查看>>
springboot集成mqtt
查看>>
Java 数组 之 一维数组 删除 元素
查看>>
【学习笔记】Android控件的使用
查看>>
mac 下载软件无法将程序拖移至app 出现错误
查看>>
关于int(1)和int(10)的区别
查看>>
动态域名解析制作
查看>>
多线程消费者和制造者的金典案例!!
查看>>
Docker快速验证HTML导出PDF高效方案
查看>>
fh admin bootstrap 模版下载 框架
查看>>
Linux之rpm包管理
查看>>
前端文件路径
查看>>
LINUX --权限
查看>>
Tomcat的优点/功能及安装
查看>>
Spring @transactional注解和synchronized同步锁同时使用不能同步的问题
查看>>