Stream流的基本使用方法

0.常用方法

在介紹的各種方法中，凡是返回值仍然為Stream接口的為函數拼接方法，它們支持鏈式調用；而返回值不再為Stream接口的為終結方法，不再支持鏈式調用。如下表所示：

方法名方法作用方法種類是否支持鏈式調用

count	統計個數	終結	否
forEach	逐一處理	終結	否
filter	過濾	函數拼接	是
limit	取用前幾個	函數拼接	是
skip	跳過前幾個	函數拼接	是
map	映射	函數拼接	是
concat	組合	函數拼接	是

1.測試類

package com.william;import java.lang.reflect.Array; import java.util.*; import java.util.function.Consumer; import java.util.stream.Stream;/*** 終結方法count（），forEach（） 只能使用一次Stream* 使用多次會拋異常：流已被操作或關閉* Exception in thread "main" java.lang.IllegalStateException: stream has already been operated upon or closed*/ public class Test {public static void main(String[] args) {//ArrayList集合System.out.println("--------ArrayList----------");ArrayList<String> objects = new ArrayList<>();objects.add("科比");objects.add("詹姆斯");objects.add("喬丹");objects.add("姚明");objects.add("艾弗森");objects.add("奧尼爾");objects.add("加內特");Stream<String> stream = objects.stream();stream.forEach(s -> System.out.println(s));// Stream<String> stringStream = stream.filter(s -> s.length() == 3).filter(s->s.endsWith("森"));//Stream<String> stringStream = stream.filter(s -> s.startsWith("科"));// stringStream.forEach(s1 -> System.out.println(s1));System.out.println("----------Map-------------");HashMap<String, Object> map = new HashMap<>();map.put("1","value1");map.put("2","value2");map.put("3","value3");map.put("4","value4");System.out.println("---------遍歷map方式1 keys和values分開-------------"); // Set<String> strings = map.keySet(); // Collection<Object> values = map.values(); // Stream<String> stream1 = strings.stream(); // stream1.forEach(s-> System.out.println(s)); // Stream<Object> stream2 = values.stream(); // stream2.forEach(s2-> System.out.println(s2));System.out.println("---------遍歷map方式2 entrySet-------------");Set<Map.Entry<String, Object>> entries = map.entrySet();Stream<Map.Entry<String, Object>> stream3 = entries.stream(); // stream3.filter(s->s.getKey()=="1").forEach(s3-> System.out.println(s3));long count = stream3.count();System.out.println(count); // ThreadMain threadMain = new ThreadMain(); // threadMain.start(); // Thread thread = Thread.currentThread(); // // for (int i = 0; i < 100; i++) { // System.out.println( thread.getName()+" : "+thread.getId()+"main---"+i); // }System.out.println("--------------數組-------------");String[] array = {"1","2","3","4"};Stream<String> array1 = Stream.of(array);array1.forEach(sa-> System.out.println(sa));Stream<String> babys = Stream.of("火娃", "水娃", "土娃", "金剛娃", "葫蘆娃", "千里眼", "順風耳", "爺爺", "蛇精");babys.filter(s -> s.contains("娃")).filter(s -> s.length()==3).forEach(s -> System.out.println(s));System.out.println("----------limit&skip------------");//String[] limitDemo={"美國隊長","綠巨人","鋼鐵俠","蜘蛛俠","蜂人","黑豹","蝙蝠俠","黑寡婦"};Stream<String> limitDemoStream = Stream.of("美國隊長", "綠巨人", "鋼鐵俠", "蜘蛛俠", "蜂人", "黑豹", "蝙蝠俠", "黑寡婦");//limitDemoStream.limit(4).forEach(s -> System.out.println(s));//獲取前四個//獲取前四個的后兩個limitDemoStream.limit(4).skip(2).forEach(s -> System.out.println(s));System.out.println("-------將stream轉換為persion對象------------");Stream<String> limitDemoStream1 = Stream.of("美國隊長", "綠巨人", "鋼鐵俠", "蜘蛛俠", "蜂人", "黑豹", "蝙蝠俠", "黑寡婦");limitDemoStream1.map(s -> new Persion(s)).forEach(s-> System.out.println(s));System.out.println("--------將stream流進行合并--------------");Stream<String> limitDemoStream11 = Stream.of("美國隊長", "綠巨人", "鋼鐵俠", "蜘蛛俠", "蜂人", "黑豹", "蝙蝠俠", "黑寡婦");Stream<String> babys1 = Stream.of("火娃", "水娃", "土娃", "金剛娃", "葫蘆娃", "千里眼", "順風耳", "爺爺", "蛇精");Stream.concat(babys1,limitDemoStream11).forEach(s -> System.out.println(s));} }

2.實體類Persion

package com.william;public class Persion {private String name;public Persion(String name) {this.name = name;}public Persion() {}@Overridepublic String toString() {return "Persion{" +"name='" + name + '\'' +'}';}public String getName() {return name;}public void setName(String name) {this.name = name;} } package com.asx.application.common.utils;import java.util.*; import java.util.stream.Collectors; //Stream（流）是一個來自數據源的元素隊列并支持聚合操作 // // 元素是特定類型的對象，形成一個隊列。 Java中的Stream并不會存儲元素，而是按需計算。 // 數據源 流的來源。 可以是集合，數組，I/O channel， 產生器generator 等。 // 聚合操作 類似SQL語句一樣的操作， 比如filter, map, reduce, find, match, sorted等。 // 和以前的Collection操作不同， Stream操作還有兩個基礎的特征： // // Pipelining: 中間操作都會返回流對象本身。 這樣多個操作可以串聯成一個管道， 如同流式風格（fluent style）。 這樣做可以對操作進行優化， 比如延遲執行(laziness)和短路( short-circuiting)。 // 內部迭代： 以前對集合遍歷都是通過Iterator或者For-Each的方式, 顯式的在集合外部進行迭代， 這叫做外部迭代。 Stream提供了內部迭代的方式， 通過訪問者模式(Visitor)實現。 public class demo {public static void main(String[] args) {//List<String> strings = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");List<String> filtered = strings.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());;filtered.forEach(s-> System.out.println(s)); // forEach // Stream 提供了新的方法 'forEach' 來迭代流中的每個數據。以下代碼片段使用 forEach 輸出了10個隨機數Random random = new Random();random.ints().limit(10).forEach(System.out::println); // map // map 方法用于映射每個元素到對應的結果，以下代碼片段使用 map 輸出了元素對應的平方數List<Integer> numbers = Arrays.asList(3, 2, 2, 3, 7, 3, 5);// 獲取對應的平方數List<Integer> squaresList = numbers.stream().map( i -> i*i).distinct().collect(Collectors.toList());squaresList.forEach(s-> System.out.println(s));//效果相同squaresList.forEach(System.out::println);//效果相同List<String>string1 = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");// 獲取空字符串的數量long count = string1.stream().filter(string -> string.isEmpty()).count();System.out.println(count);Random random1 = new Random();random1.ints().limit(10).forEach(System.out::println); // Collectors // Collectors 類實現了很多歸約操作，例如將流轉換成集合和聚合元素。Collectors 可用于返回列表或字符串List<String>strings2 = Arrays.asList("abc", "", "bc", "efg", "abcd","", "jkl");List<String> filtered1 = strings2.stream().filter(string -> !string.isEmpty()).collect(Collectors.toList());System.out.println("篩選列表: " + filtered1);String mergedString = strings2.stream().filter(string -> !string.isEmpty()).collect(Collectors.joining(", "));System.out.println("合并字符串: " + mergedString);List<Integer> numbers12 = Arrays.asList(3, 2, 2, 3, 7, 3, 5); //統計IntSummaryStatistics stats = numbers12.stream().mapToInt((x) -> x).summaryStatistics();IntSummaryStatistics intSummaryStatistics = numbers12.stream().mapToInt((a) -> a).summaryStatistics();System.out.println("列表中最大的數 : " + stats.getMax());System.out.println("列表中最小的數 : " + stats.getMin());System.out.println("所有數之和 : " + stats.getSum());System.out.println("平均數 : " + stats.getAverage());} }

總結

以上是生活随笔為你收集整理的Stream流的基本使用方法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。