Stream流

Stream流的生成方式

Stream流的使用

生成流
通过数据源(集合，数组等)生成流
list.stream()
中间操作
一个流后面可以跟随零个或多个中间操作,其期的主要是打开流,做出某种程度的数据过滤/映射,然后返回一一个新的流,
交给下一个操作使用
filter()
终结操作
一个流只能有一个终结操作，当这个操作执行后，流就被使用"光”了,无法再被操作。所以这必定是流的最后-个操作
forEach()

常见的Stream流生成方式

Collection体系的集合可以使用默认方法stream()生成流

default Stream stream()
Map体系的集合间接的生成流
- map体系无法直接生辰流,但是可以通过keySet,values,entrySet方式生成流
数组可以通过Stream接[的静态方法.(… values)生成流

//Collection体系的集合可以使用默认方法stream ()生成流
List<String> list = new ArrayList<String>();
Stream<String> listStream = list.stream();
Set<String> set = new HashSet<String>();
Stream<String> setStream = set.stream();

//Map体系的集合间接的生成流
Map<String, Integer> map = new HashMap<String, Integer>();
Stream<String> keyStream = map.keySet():stream();
Stream< Integer> valueStream = map.values().stream();
Stream<Map.Entry<String, Integer>> entryStream = map.entrySet().stream();

//数组可以通过Stream接口的静态方法of (T... values)生 成流
String[] strArray = {"he1lo", "world", "java"}; .
Stream<String> strArrayStream = Stream.of( strArray);
Stream<String> strArrayStream2 = Stream.of("he11o",
"world", "java");
Stream<Integer> intStream = Stream.of(10, 20，30);

filter(过滤流)

filter(Predicate<? super T> predicate) 
返回由与此给定谓词匹配的此流的元素组成的流。

例

//创建- -个集合，存储多个字符串元素
ArrayL ist<String> list = new ArrayList<String>();
    list.add("林青霞");
    list.add("张曼玉");
    list.add("王祖贤");
    list.add("柳岩");
    list.add("张敏");
    list.add( "张无忌");
//需求1:把list集合中以张开头的元素在控制台输出
	list.stream().filter((String s) -> {
		return s.startsWith("张");
	}).forEach(System. out: :println);
	list .stream().filter(s -> s.startsWith( "张" )).forEach(System.out::println);
	System.out.println(--------");
//需求2:把list集合中长度为3的元素在控制台输出
	list .stream().filter(s -> s.1ength() == 3). forEach(System.out::print1n);
	System.out.println("-------");
//需求3:把list集合中以张开头的，长度为3的元素在控制台输出
	list.stream().filter(s -> s.startsWith( "张")). filter(s -> s.length() == 3). 		forEach(System.out::println);

limit/skip流

Stream limit (long maxSize):返回此流中的元素组成的流，截取前指定参数个数的数据
Stream skip (iong n):跳过指定参数个数的数据，返回由该流的剩余元素组成的流

concat/distinct流

static Stream concat (Stream a, Stream b): 合并a和b两个流为-一个流
Stream distinct (): 返回由该流的不同元素(根据object. equals(Object) )组成的流

sorted流

Stream sorted(: 返回由此流的元素组成的流，根据自然顺序排序
Stream sorted(Comparator comparator):返回由该流的元素组成的流，根据提供的Comparator进行排序

map/mapToInt

Stream map(Function mapper):返回由给定函数应用于此流的元素的结果组成的流
Function接口中的方法
R apply(Tt)
IntStream mapTolnt(ToIntFunction mapper):返回一个ntStream其中包含将给定函数应用于此流的元素的结果

IntStream:表示原始int流

ToIntFunction接口中的方法 int applyAsInt(T value)

IntStream中的独有方法 int sum()
```
int result=list.strem()
    .mapToInt(Integer::parseInt).sum().foreach(System.out::Println);
```

Stream流常见的终结方式

Stream流的常见终结操作方法
void forEach(Consumer action):对此流的每个元素执行操作
Consumer接口中的方法
void accept(T t):对给定的参数执行此操作
long count():返回此流中的元素数

Stream流收集方式

对数据使用Stream流的方式操作完毕后,我想把流中的数据收集到集合中，该怎么办呢?
Stream流的收集方法
- R collect(Collector collector)
- 但是这个收集方法的参数是一 -个Collector 接口
工具类Collectors提供了具体的收集方式
- public static Collector toList():把元素收集到List集合中
- public static Collector toSet0:把元素收集到Set集合中
- public static Collector toMap(Function keyMapper,Function valueMapper):把元素收集到Map集合中

文章作者: Alex

文章连结: /archives/javastream

微信扫一扫