解決JDK8的ParallelStream遍歷無(wú)序的問(wèn)題

更新時(shí)間：2021年07月28日 10:44:22 作者：hzoboy

這篇文章主要介紹了解決JDK8的ParallelStream遍歷無(wú)序的問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教

JDK8的ParallelStream遍歷無(wú)序

ParallelStream其實(shí)就是一個(gè)并行執(zhí)行的流

它通過(guò)默認(rèn)的ForkJoinPool，可能提高你的多線程任務(wù)的速度.

Stream具有平行處理能力，處理的過(guò)程會(huì)分而治之，也就是將一個(gè)大任務(wù)切分成多個(gè)小任務(wù)，這表示每個(gè)任務(wù)都是一個(gè)操作，因此像以下的程式片段：

List    
       list = Arrays.asList(1, 2, 3, 4, 5);
list.parallelStream().forEach(out::println);

你得到的展示順序不一定會(huì)是1、2、3、4、5，而可能是任意的順序，就forEach()這個(gè)操作來(lái)講，如果平行處理時(shí)，希望最后順序是按照原來(lái)Stream的數(shù)據(jù)順序，那可以調(diào)用forEachOrdered()。

List    
       list = Arrays.asList(1, 2, 3, 4, 5);
list.parallelStream().forEachOrdered(out::println);

parallelStream進(jìn)行遍歷的坑,以及如何進(jìn)行避免異步操作中出現(xiàn)的問(wèn)題

Java8 已經(jīng)很久了，現(xiàn)在都已經(jīng)Java12版本了.

我所在的上家公司，在寫(xiě)代碼時(shí)候推薦使用lambad來(lái)進(jìn)行操作遍歷集合

也就是像下面一樣

List<Integer> list = new ArrayList<>();
for (int j = 0; j < 1000; j++) {
list.add(j);
}
list.stream().forEach(value -> {
System.out.println(value);
});

這種效率其實(shí)和傳統(tǒng)上的使用foreach以及for循環(huán)遍歷效果差不多，因?yàn)辄c(diǎn)開(kāi)forEach方法會(huì)發(fā)現(xiàn)內(nèi)部其實(shí)使用的是下面的方法進(jìn)行對(duì)集合遍歷的

內(nèi)部其實(shí)使用的還是for進(jìn)行遍歷，所以兩者相比較其實(shí)沒(méi)有什么效率的差異的，當(dāng)然這也會(huì)由于每個(gè)公司編程習(xí)慣不一樣，有的人更喜歡傳統(tǒng)上的for進(jìn)行遍歷

因?yàn)樯厦娴谋闅v方式不會(huì)對(duì)效率有什么提升, 所以由此還有一種方式就是

parallelStream()

List<Integer> list = new ArrayList<>();
for (int j = 0; j < 1000; j++) {
list.add(j);
}
list.parallelStream().forEach(value -> {
System.out.println(value);
});

上面的方法其實(shí)就是異步的，

這種遍歷方式因?yàn)槭钱惒奖闅v，會(huì)產(chǎn)生一種情況，就是遍歷的順序是無(wú)序的，當(dāng)然也有相應(yīng)的好處就是，遍歷速度會(huì)快，當(dāng)對(duì)生成結(jié)果不考慮排序問(wèn)題而且數(shù)據(jù)量比較大的時(shí)候可以使用.

但是，有利自然有弊，因?yàn)楫惒降乃孕枰紤]線程的問(wèn)題，就是生成的結(jié)果真的是你想要的么?

以下面的例子來(lái)運(yùn)行一段代碼：

public static void main(String[] args) {
List<Integer> list = new ArrayList<>();
for (int j = 0; j < 1000; j++) {
list.add(j);
}
System.out.println("最開(kāi)始生成的集合長(zhǎng)度:"+list.size());
//parallelStream遍歷數(shù)據(jù)的時(shí)候會(huì)產(chǎn)生丟失的問(wèn)題
for (int i = 0; i < 10 ; i++) {
  
List<Integer> parseList = new ArrayList<>();
list.parallelStream().forEach(integer -> {
parseList.add(integer);
});
System.out.println("每次遍歷的集合長(zhǎng)度:"+ parseList.size());
}
}

我首先創(chuàng)建了一個(gè)1000長(zhǎng)度的集合，之后對(duì)這個(gè)集合使用多次遍歷，然而呢，會(huì)發(fā)現(xiàn)，最后遍歷的集合少數(shù)據(jù)，并且會(huì)在多次重復(fù)遍歷的時(shí)候數(shù)組越界..

因?yàn)檫@種情況，之前工作使用parallelStream出現(xiàn)過(guò)2次問(wèn)題，我一直以為是使用parallelStream本身不夠很安全導(dǎo)致的.實(shí)際上今天整理這篇博文突然才發(fā)現(xiàn)這個(gè)問(wèn)題，就是遍歷的結(jié)果轉(zhuǎn)為的list是線程安全的么?

其實(shí)當(dāng)正常進(jìn)行遍歷的時(shí)候，可以對(duì)遍歷出的結(jié)果核對(duì)，實(shí)際上每次遍歷出的結(jié)果，仍然是與原來(lái)生成的結(jié)果一致的.

所以這邊只能將鍋甩在接收這些數(shù)據(jù)的list上面了

這個(gè)時(shí)候就需要對(duì)list進(jìn)行包裝

List<Integer> synchronizedList = Collections.synchronizedList(parseList);

這會(huì)在看下修改后的代碼以及結(jié)果

public static void main(String[] args) {
List<Integer> list = new ArrayList<>();
for (int j = 0; j < 1000; j++) {
list.add(j);
}
System.out.println("最開(kāi)始生成的集合長(zhǎng)度:"+list.size());
//parallelStream遍歷數(shù)據(jù)的時(shí)候會(huì)產(chǎn)生丟失的問(wèn)題
for (int i = 0; i < 10 ; i++) {
  
List<Integer> parseList = new ArrayList<>();
List<Integer> synchronizedList = Collections.synchronizedList(parseList);
list.parallelStream().forEach(integer -> {
synchronizedList.add(integer);
});
System.out.println("每次遍歷的集合長(zhǎng)度:"+ synchronizedList.size());
}
}