【Java】Stream流是什么,如何使用Stream流?

2023-10-23 09:53:41 浏览数 (2)

Stream流

Stream流

Stream流结合了Lambda表达式,简化了集合、数组的操作。

使用步骤:

①得到一条Stream流,并将数据放上去。

②使用中间方法对流水线上的数据进行操作。

③使用终结方法对流水线上的数据进行操作。

小案例:

代码语言:javascript复制
import java.util.ArrayList;

public class StreamDemo {
	public static void main(String[] args) {
		/*
		 * 创建集合、添加元素,使用Stream流,
		 * ①将开头为“张”的元素添加进新集合
		 * ②之后将长度为3的元素添加进新集合
		 * ③遍历
		 */
		
		ArrayList<String> list = new ArrayList<>();
		list.add("张三丰");
		list.add("张无忌");
		list.add("张强");
		list.add("王麻子");
		list.add("小李");
		
		//获取对象stream流,添加过滤条件,遍历
		list.stream()
		    .filter(name -> name.startsWith("张"))
		    .filter(name -> name.length() == 3)
		    .forEach(name -> System.out.println(name));
	}
}

获取Stream流:

  • default Stream<E> stream():单列集合获取Stream流(Collection的默认方法)
  • public static <T> Stream<T> stream(T[] array):数组获取Stream流(Arrays工具类中的静态方法)
  • public static <T> stream<T> of(T... values):获取一堆零散数据的Stream流(Stream接口中的静态方法,数据需要统一类型)
  • 双列集合无法直接获取Stream流,需要先使用keySet() / entrySet()再对获取到的集合使用stream()获取。

Stream流中间方法:

  • Stream<T> filter(Predicate<? super T> predicate):过滤
  • Stream<T> limit(long maxSize):Stream流获取前maxSize个元素
  • Stream<T> skip(long n):跳过前n个元素获取元素
  • Stream<T> distance():元素去重,依赖HashCode() 和 equals()
  • static <T> Stream<T> concat(Stream a,Stream b):将两个流合并为一个流
  • Stream<R> map(Function<T,R> mapper):转换流中的数据类型,参数是函数式的,需重写其方法以设置转换规则,泛型依次是原本类型,转换的类型。
    • 中间方法、返回新的Stream流,流只能使用一次,建议链式编程。
    • 修改Stream流中的数据,原本集合或数组的数据不变。

Stream流的终结方法:

void forEach(Consumer action):遍历

long count():统计

toArray():将流中的数据放入数组

collect(Collector collector):将流中的数据放入集合

  • Collectors.toList()
  • Collectors.toSet()
  • Collectors.toMap(a,b):a,b两个函数式接口,需要编写匿名内部类,重写方法,指定数据转换规则。

案例:

代码语言:javascript复制
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.stream.Collector;
import java.util.stream.Collectors;

public class StreamDemo {
	public static void main(String[] args) {	
		
		/*定义集合,添加数据,留下偶数*/
		ArrayList<Integer> listInt = new ArrayList<>();
		Collections.addAll(listInt, 1,2,3,4,5,6,7,8,9,10);
		listInt.stream().filter(s -> s.intValue() % 2 == 0).forEach(i -> System.out.println(i));
		
		System.out.println("-------------------------------");
		
		/*定义集合,添加姓名,年龄数据,保留年龄大于24的人,数据存入Map集合*/
		ArrayList<String> listName = new ArrayList<>();
		Collections.addAll(listName, "张三,18","李四,24","小品,24","小豪,29","张无忌,16","脉哦,22");
		Map<String,Integer> mapName = listName.stream()
		        .filter(s -> Integer.parseInt(s.split(",")[1]) >= 24)
		        .collect(Collectors.toMap(
		        		s -> s.split(",")[0] ,
		        		s -> Integer.parseInt(s.split(",")[1])));
		mapName.entrySet().forEach(s -> System.out.println(s.getKey()   "--"   s.getValue()));
		
		
	}
}

0 人点赞