package com.atguigu.java8;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Iterator;

import java.util.List;

import java.util.stream.Stream;

import org.junit.Test;

/*

* 一、Stream API 的操作步驟：

*

* 1. 創(chuàng)建 Stream

*

* 2. 中間操作

*

* 3. 終止操作(終端操作)

*/

public class TestStreamAPI {

//1. 創(chuàng)建 Stream

@Test

public void test1(){

//1. Collection 提供了兩個(gè)方法 stream() 與 parallelStream()

List list = new ArrayList<>();

Stream stream = list.stream(); //獲取一個(gè)順序流

Stream parallelStream = list.parallelStream(); //獲取一個(gè)并行流

//2. 通過 Arrays 中的 stream() 獲取一個(gè)數(shù)組流

Integer[] nums = new Integer[10];

Stream stream1 = Arrays.stream(nums);

//3. 通過 Stream 類中靜態(tài)方法 of()

Stream stream2 = Stream.of(1,2,3,4,5,6);

//4. 創(chuàng)建無限流

//迭代

Stream stream3 = Stream.iterate(0, (x) -> x + 2).limit(10);

stream3.forEach(System.out::println);

//生成

Stream stream4 = Stream.generate(Math::random).limit(2);

stream4.forEach(System.out::println);

}

//2. 中間操作

List emps = Arrays.asList(

new Employee(102, "李四", 59, 6666.66),

new Employee(101, "張三", 18, 9999.99),

new Employee(103, "王五", 28, 3333.33),

new Employee(104, "趙六", 8, 7777.77),

new Employee(104, "趙六", 8, 7777.77),

new Employee(104, "趙六", 8, 7777.77),

new Employee(105, "田七", 38, 5555.55)

);

/*

篩選與切片

filter——接收 Lambda ， 從流中排除某些元素。

limit——截?cái)嗔?#xff0c;使其元素不超過給定數(shù)量。

skip(n) —— 跳過元素，返回一個(gè)扔掉了前 n 個(gè)元素的流。若流中元素不足 n 個(gè)，則返回一個(gè)空流。與 limit(n) 互補(bǔ)

distinct——篩選，通過流所生成元素的 hashCode() 和 equals() 去除重復(fù)元素

*/

//內(nèi)部迭代：迭代操作 Stream API 內(nèi)部完成

@Test

public void test2(){

//所有的中間操作不會做任何的處理

Stream stream = emps.stream()

.filter((e) -> {

System.out.println("測試中間操作");

return e.getAge() <= 35;

});

//只有當(dāng)做終止操作時(shí)，所有的中間操作會一次性的全部執(zhí)行，稱為“惰性求值”

stream.forEach(System.out::println);

}

//外部迭代

@Test

public void test3(){

Iterator it = emps.iterator();

while(it.hasNext()){

System.out.println(it.next());

}

}

@Test

public void test4(){

emps.stream()

.filter((e) -> {

System.out.println("短路！"); // && ||

return e.getSalary() >= 5000;

}).limit(3)

.forEach(System.out::println);

}

@Test

public void test5(){

emps.parallelStream()

.filter((e) -> e.getSalary() >= 5000)

.skip(2)

.forEach(System.out::println);

}

@Test

public void test6(){

emps.stream()

.distinct()

.forEach(System.out::println);

}

}

總結(jié)

以上是生活随笔為你收集整理的java8 list切片_Java8新特性_创建 Stream、流筛选与切片的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。