Stream是資料渠道，用于操作集合、陣列等生成的元素序列，
Stream操作的三個步驟：
-
創建Stream
-
中間操作
-
終止操作
一、獲取stream的四種方式
- 通過
collection系列集合的stream()或parallelStream()獲取，
@Test
void test11(){
List<String> list = new ArrayList<>();
Stream<String> stringStream = list.stream();
}
- 通過
Arrays中的靜態方法stream()獲取陣列流，
@Test
void test11(){
Person[] person = new Person[10];
Arrays.stream(person);
}
- 通過
Stream中的靜態方法of()，
@Test
void test11(){
Stream<String> stream = Stream.of("a", "b", "c");
}
- 創建無限流
/**
* 迭代
*/
@Test
void test11(){
Stream<Integer> integerStream = Stream.iterate(0, x -> x + 2);
}
/**
* 生成
*/
@Test
void test11(){
Stream.generate(() -> Math.random());
}
二、中間操作
中間操作不會執行任何操作，只有終止操作才會一次性輸出全部值，即“惰性求值”，
2.1 篩選與切片
filter——接收lamdba，從流中排除某些元素
@Test
void test12(){
List<Person> personList = Arrays.asList(
new Person("Java旅途",18),
new Person("Java旅途",20)
);
// 中間操作
Stream<Person> personStream = personList.stream()
.filter(e -> e.getAge() > 18);
// 終止操作
personStream.forEach(System.out::println);
}
limit——截斷流，使其元素不超過給定數量
@Test
void test12(){
List<Person> personList = Arrays.asList(
new Person("Java旅途",18),
new Person("Java旅途",20)
);
personList.stream()
.limit(1)
.forEach(System.out::println);
}
skip(n)——跳過元素，回傳一個扔掉前n個元素的流，若不足n個，則回傳一個空流，與limit(n)互補，
@Test
void test12(){
List<Person> personList = Arrays.asList(
new Person("Java旅途",18),
new Person("Java旅途",20)
);
personList.stream()
.skip(1)
.forEach(System.out::println);
}
distinct——篩選，通過生成元素的hashCode()和equals()，去除重復元素，
@Test
void test12(){
List<Person> personList = Arrays.asList(
new Person("Java旅途",18),
new Person("Java旅途",20),
new Person("Java旅途",20)
);
personList.stream()
.distinct()
.forEach(System.out::println);
}
注意：使用distinct的時候需要重寫物體的hashCode()和equals()方法，
2.2 映射
map——接收lamdba，將元素轉換成其他形式或提取資訊，接收一個函式作為引數，該函式會被應用到每個元素上，并將其映射成一個新的元素，
/**
* 獲取personList的所有name
*/
@Test
void test13(){
List<Person> personList = Arrays.asList(
new Person("Java旅途",18),
new Person("Java旅途",20),
new Person("Java旅途",20)
);
personList.stream()
.map(Person::getName)
.forEach(System.out::println);
}
flatMap——接收一個函式作為引數，將流中的每個值都換成另一個流，然后把所有流生成一個流，
// 將字串轉換為字符，并將字符放進list回傳
static Stream<Character> filterCharcter(String string){
List<Character> list = new ArrayList<>();
for (Character ch : string.toCharArray()){
list.add(ch);
}
return list.stream();
}
@Test
void test13(){
List<String> list = Arrays.asList("aaa","bbb","ccc");
list.stream()
.flatMap(LamdbaApplicationTests::filterCharcter)
.forEach(System.out::println);
}
2.3 排序
sorted()——自然排序（comparable）sorted(comparator com)——定制排序（comparator ）
/**
* 定制排序，e1和e2按age排序，age一樣按name排
*/
@Test
void test14(){
List<Person> personList = Arrays.asList(
new Person("Java旅途",18),
new Person("Java旅途",20)
);
personList.stream()
.sorted((e1,e2) -> {
if(e1.getAge() == e2.getAge()){
return e1.getName().compareTo(e2.getName());
}else{
return e1.getAge()+"".compareTo(e2.getAge()+"");
}
}).forEach(System.out::println);
}
三、終止操作
3.1 查找與匹配
完善一下Person類
@Data
public class Person implements Serializable {
private static final long serialVersionUID = -7008474395345458049L;
private String name;
private int age;
private Status status;
public Person() {
}
public Person(String name, int age) {
this.name = name;
this.age = age;
}
public Person(String name, int age, Status status) {
this.name = name;
this.age = age;
this.status = status;
}
public enum Status {
FRER,
BUSY;
}
}
allMatch——檢查是否匹配所有元素
/**
* 是否所有元素都是Fire狀態，是回傳true
*/
@Test
void test15(){
List<Person> personList1 = Arrays.asList(
new Person("Java旅途",18, Person.Status.FRER),
new Person("Java旅途",20, Person.Status.BUSY)
);
boolean b = personList1.stream()
.allMatch(e -> e.getStatus().equals(Person.Status.FRER));
System.out.println(b);
}
anyMatch——檢查是否至少匹配一個元素
@Test
void test15(){
List<Person> personList1 = Arrays.asList(
new Person("Java旅途",18, Person.Status.FRER),
new Person("Java旅途",20, Person.Status.BUSY)
);
boolean b = personList1.stream()
.anyMatch(e -> e.getStatus().equals(Person.Status.FRER));
System.out.println(b);
}
noneMatch——檢查是否所有元素都不匹配
@Test
void test15(){
List<Person> personList1 = Arrays.asList(
new Person("Java旅途",18, Person.Status.FRER),
new Person("Java旅途",20, Person.Status.BUSY)
);
boolean b = personList1.stream()
.noneMatch(e -> e.getStatus().equals(Person.Status.FRER));
System.out.println(b);
}
findFirst——回傳第一個元素
@Test
void test15(){
List<Person> personList1 = Arrays.asList(
new Person("Java旅途",18, Person.Status.FRER),
new Person("Java旅途",20, Person.Status.BUSY)
);
Optional b = personList1.stream()
.findFirst();
System.out.println(b.get());
}
findAny——回傳當前流中的任意元素
@Test
void test15(){
List<Person> personList1 = Arrays.asList(
new Person("Java旅途",18, Person.Status.FRER),
new Person("Java旅途",20, Person.Status.BUSY)
);
Optional b = personList1.stream()
.findAny();
System.out.println(b.get());
}
count——回傳流中元素的總數max——回傳流中最大值min——回傳流中最小值
3.2 規約
reduce(T identity, BinaryOperator)/reduce(BinaryOperator)——可以將流中元素反復結合起來，得到一個值，
/**
* reduce 第一個引數是起始值
*/
@Test
void test16(){
List<Integer> list = Arrays.asList(1,2,3,4,5,6,7,8,9,10);
Integer sum = list.stream()
.reduce(0,(x,y) -> x+y);
System.out.println(sum);
Optional<Integer> reduce = list.stream()
.reduce((x, y) -> x + y);
System.out.println(reduce.get());
}
3.3 收集
collect——將流轉化為其他形式，接收一個Collector介面的實作，用于給Stream中元素做匯總的方法，
/**
* 取出名字放在一個list中
*/
@Test
void test16(){
List<Person> personList1 = Arrays.asList(
new Person("Java旅途",18, Person.Status.FRER),
new Person("Java旅途",20, Person.Status.BUSY)
);
List<String> collect = personList1.stream()
.map(Person::getName)
.collect(Collectors.toList());
collect.forEach(System.out::println);
}
Optional常用方法
Optional類是一個容器類，代表一個值存在或不存在，原來用null表示一個值不存在，現在Optional可以更好的表達這個概念，并且可以避免空指標例外，
-
Optional.of(T t) ——創建一個Optional實體
-
Optional.empty()——創建一個空的optional實體
-
Optional.ofNullable(T t)——若t不為null，創建optional實體，否則創建空實體
-
isPresent()——判斷是否包含值
-
orElse(T t)——如果呼叫物件包含值，回傳該值，否則回傳 t
-
orElseGet(Supplier s)——如果呼叫物件包含值，回傳該值，否則回傳 s 獲取的值
-
map(Function f)——如果有值對其處理，并回傳處理后的Optional，否則回傳Optional.empty()
-
flatMap(Function mapper)——與map類似，要求回傳值必須是Optional
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/141639.html
標籤：Java