Java8 Stream,過分絲滑!
往期熱門文章:
文章來源:https://c1n.cn/5n6fT
目錄
Stream 流
Stream 流的使用
Stream 流
Stream 流是什么,為什么要用它?
Stream是 Java8 新引入的一個包( java.util.stream),它讓我們能用聲明式的方式處理數(shù)據(jù)(集合、數(shù)組等)。
Stream流式處理相較于傳統(tǒng)方法簡潔高效,也便于進行并發(fā)編程。
Stream 流的使用
| 簡單綜合案例
傳統(tǒng)方法:
import java.util.ArrayList;
import java.util.List;
public class Demo02NormalFilter {
public static void main(String[] args) {
List<String> list = new ArrayList<>();
list.add("阿拉貢");
list.add("阿爾玟");
list.add("埃爾隆德");
list.add("凱蘭崔爾");
list.add("瑟蘭督伊");
List<String> zhangList = new ArrayList<>();
for (String name : list) {
if (name.startsWith("阿")) {
zhangList.add(name);
}
}
List<String> shortList = new ArrayList<>();
for (String name : zhangList) {
if (name.length() == 3) {
shortList.add(name);
}
}
for (String name : shortList) {
System.out.println(name);
}
}
}
首先篩選所有姓“阿”的人
然后篩選名字有三個字的人
最后進行對結果進行打印輸出
Stream 流式處理方法:
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Stream;
public class Demo02NormalFilter {
public static void main(String[] args) {
List<String> list = new ArrayList<>();
list.add("阿拉貢");
list.add("阿爾玟");
list.add("埃爾隆德");
list.add("凱蘭崔爾");
list.add("瑟蘭督伊");
list.stream()
.filter(s ‐> s.startsWith("阿"))
.filter(s ‐> s.length() == 3)
.forEach(System.out::println);
}
}
| 獲取流
①根據(jù) Collection 獲取流
import java.util.*;
import java.util.stream.Stream;
public class Demo04GetStream {
public static void main(String[] args) {
List<String> list = new ArrayList<>();
Stream<String> stream1 = list.stream();
Set<String> set = new HashSet<>();
Stream<String> stream2 = set.stream();
Vector<String> vector = new Vector<>();
Stream<String> stream3 = vector.stream();
}
}
②根據(jù) Map 獲取流
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Stream;
public class Demo05GetStream {
public static void main(String[] args) {
Map<String, String> map = new HashMap<>();
//Stream流的轉化需要單列數(shù)據(jù),那么我們就先把map里面的數(shù)據(jù)變成單列的再轉化為流
Stream<String> keyStream = map.keySet().stream();
Stream<String> valueStream = map.values().stream();
Stream<Map.Entry<String, String>> entryStream = map.entrySet().stream();
}
}
import java.util.stream.Stream;
public class Demo06GetStream {
public static void main(String[] args) {
String[] array = { "阿拉貢", "阿爾玟", "埃爾隆德", "凱蘭崔爾","瑟蘭督伊" };
Stream<String> stream = Stream.of(array);
}
}
| 常用方法
延遲方法:返回值類型仍然是 Stream 接口自身類型的方法,因此支持鏈式調用。(除了終結方法外,其余方法均為延遲方法)
終結方法:返回值類型不再是 Stream 接口自身類型的方法,因此不再支持類似 StringBuilder 那樣的鏈式調用。(如果想知道更多方法,建議自行參考 API 文檔)
①逐一處理:forEach
方法簽名:
void forEach(Consumer<? super T> action);
基本使用:
import java.util.stream.Stream;
public class Demo12StreamForEach {
public static void main(String[] args) {
Stream<String> stream = Stream.of("阿拉貢", "阿爾玟", "埃爾隆德");
stream.forEach(name‐> System.out.println(name));
}
}
篩選:filter
方法簽名:
Stream<T> filter(Predicate<? super T> predicate);
基本使用:
import java.util.stream.Stream;
public class Demo07StreamFilter {
public static void main(String[] args) {
Stream<String> original = Stream.of("阿拉貢", "阿爾玟", "埃爾隆德");
Stream<String> result = original.filter(s ‐> s.startsWith("阿"));
}
}
映射:map
方法簽名:
<R> Stream<R> map(Function<? super T, ? extends R> mapper);
基本使用:
import java.util.stream.Stream;
public class Demo08StreamMap {
public static void main(String[] args) {
Stream<String> original = Stream.of("10", "12", "18");
Stream<Integer> result = original.map(str‐>Integer.parseInt(str));
}
}
統(tǒng)計個數(shù):count
方法簽名:
long count();
基本使用:
import java.util.stream.Stream;
public class Demo09StreamCount {
public static void main(String[] args) {
Stream<String> original = Stream.of("阿拉貢", "阿爾玟", "埃爾隆德");
Stream<String> result = original.filter(s ‐> s.startsWith("阿"));
System.out.println(result.count()); // 2
}
}
取用前幾個:limit
方法簽名:
Stream<T> limit(long maxSize);
基本使用:
import java.util.stream.Stream;
public class Demo10StreamLimit {
public static void main(String[] args) {
Stream<String> original = Stream.of("阿拉貢", "阿爾玟", "埃爾隆德");
Stream<String> result = original.limit(2);
System.out.println(result.count()); // 2
}
}
跳過前幾個:skip
方法簽名:
Stream<T> skip(long n);
基本使用:
import java.util.stream.Stream;
public class Demo11StreamSkip {
public static void main(String[] args) {
Stream<String> original = Stream.of("阿拉貢", "阿爾玟", "埃爾隆德");
Stream<String> result = original.skip(2);
System.out.println(result.count()); // 1
}
}
②組合:concat
方法簽名:
static <T> Stream<T> concat(Stream<? extends T> a, Stream<? extends T>b)
基本使用:
import java.util.stream.Stream;
public class Demo12StreamConcat {
public static void main(String[] args) {
Stream<String> streamA = Stream.of("阿拉貢");
Stream<String> streamB = Stream.of("阿爾玟");
Stream<String> result = Stream.concat(streamA, streamB);
}
}
最近熱文閱讀:
1、8 種最坑SQL語法,工作中踩過嗎? 2、Java 語言“坑爹” TOP 10 3、你還不明白如何解決分布式Session?看這篇就夠了! 4、能解決 80% 故障的排查思路 5、程序員坐牢了,會被安排寫代碼嗎? 6、面試被問Nginx,怎么破? 7、為什么很多 SpringBoot 開發(fā)者放棄了 Tomcat,選擇了 Undertow? 8、數(shù)據(jù)庫日期類型字段設計,應該如何選擇? 9、40 個 SpringBoot 常用注解:讓生產力爆表! 10、3種常見的數(shù)據(jù)脫敏方案 關注公眾號,你想要的Java都在這里
評論
圖片
表情
