xuedinge
xuedinge
感谢您的科普,我也顺利用上了流。 在实际使用并行流的时候遇到了一个oom。 大致情况是要处理一个四十多m的txt文件,内容为换行的字符串。 使用lines.flatMap(line -> Arrays.stream(line.split(" "))).parallel().distinct().count();做并发计算词语个数(数量大概在三百万,类似 一@一对一 5 一@一道 5 一@丁 6 一@七旬 8 一@万 157)。 执行期间,并行流吃光了我的内存,cpu,我jvm中的old跟eden全部爆满,方法区正常,线程正常。 串行与外部迭代只会吃掉五十m内存。 请教作者,是我并发流用的不对,还是jdk8的流有bug ---下面是重现代码 static void useStream(){ long uniqueWord = 0; try (Stream...
this issues occurs when i calculate array size, this array about three minion arays,i hava 2G heap.this file is only 40m,and if i use no parallel,this program only uses 50m,...