本文章為系列文章，上一篇《??Stream案例體驗(yàn)??》通過豐富的案例感受了Stream的便利，本篇主要講解：
- Stream的運(yùn)行流程，結(jié)合本篇和上一篇案例體會(huì)
- Stream的創(chuàng)建方式
- Stream的操作分類
- 串行流和并行流區(qū)別
Stream運(yùn)行流程
這里通過一個(gè)運(yùn)費(fèi)案例，通過 【代碼實(shí)現(xiàn)】 +【 圖解】解釋清楚Stream計(jì)算數(shù)據(jù)時(shí)的流程！
需求：獲取運(yùn)單價(jià)格大于 5000元 的運(yùn)單編號(hào)
分析：
- 創(chuàng)建運(yùn)單數(shù)據(jù)
- 通過集合的stream方法創(chuàng)建流
- 再通過調(diào)用流對(duì)象的 filter方法過濾出需要的數(shù)據(jù)【中間操作】
- 再通過流對(duì)象的map方法獲取想要的字段數(shù)據(jù)【中間操作】
- 在通過collect方法將流對(duì)象轉(zhuǎn)換為集合，終止流【終止操作】
代碼實(shí)現(xiàn)：
運(yùn)單類可直接復(fù)用 《??Stream案例體驗(yàn)??》一篇
import java.math.BigDecimal;
import java.util.*;
import java.util.stream.Collectors;
import java.util.stream.Stream;
public class WaybillMain {
private static List<Waybill> waybills = new ArrayList<>();
static {
// 創(chuàng)建數(shù)據(jù)
waybills.add(new Waybill(1L,"Y11111111111",new BigDecimal(1000),"鋼材",new BigDecimal(200),"上海市"));
waybills.add(new Waybill(2L,"Y22222222222",new BigDecimal(2000),"鋼材",new BigDecimal(300),"鄭州市"));
waybills.add(new Waybill(3L,"Y33333333333",new BigDecimal(3000),"水泥",new BigDecimal(300),"北京市"));
waybills.add(new Waybill(4L,"Y44444444444",new BigDecimal(4000),"水泥",new BigDecimal(400),"廣州市"));
waybills.add(new Waybill(5L,"Y55555555555",new BigDecimal(5000),"沙子",new BigDecimal(500),"上海市"));
waybills.add(new Waybill(6L,"Y66666666666",new BigDecimal(6000),"板材",new BigDecimal(500),"深圳市"));
waybills.add(new Waybill(7L,"Y77777777777",new BigDecimal(7000),"蔬菜",new BigDecimal(500),"杭州市"));
}
public static void main(String[] args){
// 1、獲取運(yùn)費(fèi)大于5000的運(yùn)單編號(hào)
// 1) 通過集合的stream方法創(chuàng)建流
Stream<Waybill> stream = waybills.stream();
// 2) 通過 filter 方法篩選運(yùn)單大于5000的運(yùn)單
Stream<Waybill> filterWaybill = stream.filter(item -> item.getPrice().compareTo(new BigDecimal(5000)) == 1);
// 3) 獲取篩選后的運(yùn)單的編號(hào)
Stream<String> wayNoStream = filterWaybill.map(Waybill::getWayNo);
// 4) 將流轉(zhuǎn)換為新的集合
List<String> wayNoList = wayNoStream.collect(Collectors.toList());
// 5) 遍歷
wayNoList.forEach(System.out::println);
}
}
運(yùn)行流程：
Stream操作分類
上節(jié)我們說，Stream的操作分為兩大類，【中間操作】和【結(jié)束操作】，這里詳細(xì)介紹一下
無狀態(tài)：元素的處理不受之前元素影響，比如：過濾，映射，轉(zhuǎn)換類型
有狀態(tài)：該元素只有拿到所有元素之后才能繼續(xù)下去，比如排序，去重
非短路操作：必須處理完所有元素才能得到結(jié)果，比如：求最值，遍歷
短路操作：遇到某些符合條件的元素就可以得到最終結(jié)果，比如：獲取第一個(gè)出現(xiàn)的數(shù)據(jù)
Stream創(chuàng)建
流可以用來處理數(shù)組、集合、IO資源等數(shù)據(jù)，而且分為【串行流】和【并行流】?jī)煞N，它的創(chuàng)建方式主要分為以下幾種：
使用Collection下的stream() 方法【串行流】和parallelStream() 方法【并行流】
List<String> list = Arrays.asList("a", "b", "c");
// 創(chuàng)建一個(gè)順序流
Stream<String> stream = list.stream();
// 創(chuàng)建一個(gè)并行流
Stream<String> parallelStream = list.parallelStream();使用Arrays中的stream() 方法，將數(shù)組轉(zhuǎn)換為流
int[] array={1,3,5,6,8};
IntStream stream = Arrays.stream(array);使用Stream中的靜態(tài)方法：of()、iterate()、generate()
對(duì)于iterate和generate這種沒有數(shù)據(jù)長(zhǎng)度的流稱為【無限流】，需要使用limit()來指定流長(zhǎng)度
比如generate是生成數(shù)據(jù)，生成多少數(shù)據(jù)？需要使用limit指定
Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5, 6);
// 參數(shù)1：為起始值
// 參數(shù)2：每次的值進(jìn)行什么操作，再基于結(jié)果做下一次的運(yùn)算
// limit：最多4次操作
List<Integer> iterate = Stream.iterate(1, x -> x * 3).limit(4).collect(Collectors.toList());
System.out.println(iterate);
// 生成 3 個(gè)隨機(jī)數(shù)
Stream<Double> limit = Stream.generate(Math::random).limit(3);
limit.forEach(System.out::println);
使用 BufferedReader.lines() 方法，將每行內(nèi)容轉(zhuǎn)成流
BufferedReader reader = new BufferedReader(new FileReader("D:\\stream.txt"));
Stream<String> lineStream = reader.lines();
lineStream.forEach(System.out::println);使用 Pattern.splitAsStream() 方法，將字符串分隔成流
Pattern pattern = Pattern.compile(",");
Stream<String> stringStream = pattern.splitAsStream("a,b,c,d");
stringStream.forEach(System.out::println);串行流和并行流區(qū)別
stream()方法創(chuàng)建的是【串行流】也可以叫【順序流】，由主線程按順序?qū)α鲌?zhí)行操作，而 parallelStream()方法創(chuàng)建的是【并行流】，內(nèi)部以多線程并行執(zhí)行的方式對(duì)流進(jìn)行操作，但前提是流中的數(shù)據(jù)處理沒有順序要求。例如篩選集合中的奇數(shù)，兩者的處理不同之處：
如果流中的數(shù)據(jù)量足夠大，并行流可以加快處速度。
除了直接創(chuàng)建并行流，還可以通過 parallel()把順序流轉(zhuǎn)換成并行流：
// 創(chuàng)建數(shù)組
Integer[] arr = {1,2,3,4,5,6,7,8,9,10};
// 通過 stream 轉(zhuǎn)換為串行流，再通過 Stream 對(duì)象的 parallel 方法轉(zhuǎn)換為并行流
Stream<Integer> integerStream = Arrays.stream(arr).parallel();
// 計(jì)算，并行流只能對(duì)無順序要求的計(jì)算生效
// mao：對(duì)每一個(gè)數(shù)據(jù) * 2
List<Integer> list = integerStream.map(x -> x * 2).collect(Collectors.toList());
list.forEach(System.out::println);
