做任务悬赏网站,字体 wordpress,淄博做网站的公司都有哪些,wordpress设置文章目录获取Stream流的方式 java.util.stream.Stream 是Java 8新加入的流接口。#xff08;并不是一个函数式接口#xff09; 获取一个流非常简单#xff0c;有以下几种常用的方式#xff1a;
所有 Collection 集合都可通过 stream 默认方法获取流#xff08;顺序流#xff09;…获取Stream流的方式 java.util.stream.Stream 是Java 8新加入的流接口。并不是一个函数式接口 获取一个流非常简单有以下几种常用的方式
所有 Collection 集合都可通过 stream 默认方法获取流顺序流所有 Collection 集合都可通过parallelStream获取并行流Stream 接口的静态方法 of 可以获取数组对应的流。Arrays的静态方法stream也可以获取流 根据Collection获取流
public static void main(String[] args) {ListString list new ArrayList();StreamString stream1 list.stream();SetString set new HashSet();StreamString stream2 set.stream();VectorString vector new Vector();// ...
} 根据Map获取流
public static void main(String[] args) {MapString, String map new HashMap();StreamString keyStream map.keySet().stream();StreamString valueStream map.values().stream();StreamMap.EntryString, String entryStream map.entrySet().stream();
} 根据数组获取流
如果使用的不是集合或映射而是数组由于数组对象不可能添加默认方法所以 Stream 接口中提供了静态方法of 使用很简单
public static void main(String[] args) {//使用 Stream.ofString[] array { 张无忌, 张翠山, 张三丰, 张一元 };StreamString stream Stream.of(array);//使用Arrays的静态方法Arrays.stream(array)
} Stream流中的常用方法
方法可分成两种
延迟方法返回值类型仍然是 Stream 接口自身类型的方法因此支持链式调用。除终结方法外其余方法均为延迟方法终结方法返回值类型不是 Stream 接口自身类型的方法因此不再支持类似 StringBuilder 那样的链式调用。本节中终结方法包括 count 和 forEach 方法。 1.forEach终结方法
用于遍历的方法参数传入一个函数式接口Consumer
public static void main(String[] args) {StreamString stream Stream.of(张无忌, 张三丰, 周芷若);stream.forEach(name‐ System.out.println(name));
} 2.过滤filter
可用于过滤。可通过 filter 方法将一个流转换成另一个子集流。
public static void main(String[] args) {//创建一个流StreamString stream Stream.of( 刘德华, 张国荣, 彭于晏, 纳什, 吴彦祖);//对流中元素过滤,只要姓张的人StreamString stream2 stream.filter(name - {return name.startsWith(张);});//遍历过滤后的流stream2.forEach(name - System.out.println(name));
}3.映射(转换)map
如果需要将流中的元素映射到另一个流中可用 map 方法。
该接口需要一个 Function 函数式接口参数
/*** stream流的map方法练习* map方法可以将流中的元素映射到另一个流中* map方法的参数是一个Function函数式接口*/Testpublic void test(){//创建一个流里面是字符串类型的整数StreamString stream1 Stream.of(2, 32, 2, 33, 2);//把stream1流中的整数全部转成int类型StreamInteger stream2 stream1.map((String s) - {return Integer.parseInt(s);});//遍历stream2.forEach((i)- System.out.println(i));} 4.统计个数count终结方法
正如旧集合 Collection 当中的 size 方法一样流提供 count 方法来数一数其中的元素个数
该方法返回一个long值代表元素个数不像旧集合那样是int值。
public class Demo09StreamCount {public static void main(String[] args) {StreamString original Stream.of(张无忌, 张三丰, 周芷若);//筛选姓张的StreamString result original.filter(s ‐ s.startsWith(张));//输出个数System.out.println(result.count()); // 2}
} 5.取用前几个截取limit
limit 方法可对流进行截取只取用前n个。
参数是一个long型如果集合当前长度大于参数则进行截取否则不进行操作。
public class Demo10StreamLimit {public static void main(String[] args) {StreamString original Stream.of(张无忌, 张三丰, 周芷若);//截取前两个StreamString result original.limit(2);System.out.println(result.count()); // 2}
} 6.跳过前几个元素skip
如果希望跳过前几个元素可用 skip 方法获取一个截取后的新流
如果流的当前长度大于n则跳过前n个否则将会得到一个长度为0的空流。
public class Demo11StreamSkip {public static void main(String[] args) {StreamString original Stream.of(张无忌, 张三丰, 周芷若);//跳过前两个返回一个新的流StreamString result original.skip(2);System.out.println(result.count()); // 1}
}7.组合合并流concat
如果有两个流希望合并为一个流可以用 Stream 接口的静态方法 concat
public class Demo12StreamConcat {public static void main(String[] args) {StreamString streamA Stream.of(张无忌);StreamString streamB Stream.of(张翠山);//合并成一个新的流StreamString result Stream.concat(streamA, streamB);}
} 8.筛选distinct
去除流中重复元素使用hashcode和equals方法来对比 9.映射(打开后再转换)flatMap
内部传入一个Function函数式接口跟map的区别就是这个会把流中的元素打开再组合成一个新的流
// map和flatMap的练习
public class StreamDemo {Testpublic void test(){ListString list Arrays.asList(aa,bb,cc,dd);// 练习1 (map) 输出的全是大写list.stream().map(s - s.toUpperCase()).forEach(System.out::println);System.out.println(----------);// 练习2map流里还有流需要两个遍历才行看到里面内容StreamStreamCharacter streamStream list.stream().map(StreamDemo::fromStringToStream);streamStream.forEach(s - {s.forEach(System.out::println);});System.out.println(---------);// 练习3flatMap流里还有流使用flatMap可以直接把里面的流打开一次遍历就可以了StreamCharacter characterStream list.stream().flatMap(StreamDemo::fromStringToStream);characterStream.forEach(System.out::println);}/*** 将字符串中的多个字符构成的集合转换为对应的stream* param str* return*/public static StreamCharacter fromStringToStream(String str){ArrayListCharacter list new ArrayList();// 将字符串转成字符数组并遍历加入list集合for(Character c : str.toCharArray()){list.add(c);}// 返回list集合的stream流return list.stream();}
}10.自然排序sorted
看下一条里的代码 11.定制排序sorted(Comparator com) /*** 排序的练习*/Testpublic void test2(){ListInteger integers List.of(124, 2, 15, 12, 51, -5, 5);// 按照自然排序integers.stream().sorted().forEach(System.out::println);System.out.println(---------);ListInteger integers2 List.of(124, 2, 15, 12, 51, -5, 5);// 定制排序(大到小)需要传入Comparator接口如果流中的是引用类型只能用定制排序// 简写integers2.stream().sorted((e1,e2) - e2-e1).forEach(System.out::println);integers2.stream().sorted((e1,e2) - {return e2-e1;}).forEach(System.out::println);} 12.检测匹配终结方法
返回一个Boolean值
是否全部匹配allMatch
是否至少匹配一个anyMatch
是否没有匹配的noneMatch /*** 匹配的练习*/Testpublic void test3(){ListInteger integers List.of(124, 2, 15, 12, 51, -5, 5);// 判断是否全部大于5boolean b integers.stream().allMatch(i - i 5);// 结束输出falseSystem.out.println(b);System.out.println(-------);ListInteger integers2 List.of(124, 2, 15, 12, 51, -5, 5);// 检测是否匹配至少一个元素boolean b1 integers2.stream().anyMatch(i - i 5);// 输出trueSystem.out.println(b1);System.out.println(-------);ListInteger integers3 List.of(124, 2, 15, 12, 51, -5, 5);// 检查是否没有匹配的元素boolean b2 integers3.stream().noneMatch(i - i 1000);// 输出true全部不匹配System.out.println(b2);} 13.查找元素终结方法
查找第一个元素findFirst返回Optional类型
查找其中一个元素findAny返回Optional类型
public void test4(){ListInteger integers List.of(124, 2, 15, 12, 51, -5, 5);// 输出第一个元素OptionalInteger first integers.stream().findFirst();// 输出结果是Optional[124]System.out.println(first);System.out.println(-------------);ListInteger integers2 List.of(124, 2, 15, 12, 51, -5, 5);// 返回其中一个元素OptionalInteger any integers2.stream().findAny();System.out.println(any);} 14.查找最大最小值终结方法
max(comparator c)
min(comparator c) /*** 查找最大最小值*/Testpublic void test5(){ListPerson list new ArrayList();list.add(new Person(马化腾,25,3000));list.add(new Person(李彦宏,27,2545));list.add(new Person(雷军,35,4515));list.add(new Person(马云,55,9877));// 查找年龄最大的人OptionalPerson max list.stream().max((e1, e2) - e1.getAge() - e2.getAge());// 返回马云55岁年龄最大System.out.println(max.get());System.out.println(--------); 15.规约终结方法
reduce(T identity BinaryOperator) 第一个参数是初始值第二个参数是一个函数式接口
reduce(BinaryOperator) 参数是一个函数式接口
/*** 归约的练习*/Testpublic void test6(){ListInteger integers List.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);// 求集合里数字的和归约reduce第一个参数是初始值。Integer sum integers.stream().reduce(0, Integer::sum);System.out.println(sum);System.out.println(-------);ListPerson list new ArrayList();list.add(new Person(马化腾,25,3000));list.add(new Person(李彦宏,27,2545));list.add(new Person(雷军,35,4515));list.add(new Person(马云,55,9877));// 求所有人的工资和归约// 不用方法引用写法OptionalInteger reduce list.stream().map(person - person.getSalary()).reduce((e1, e2) - e1 e2);OptionalInteger reduce list.stream().map(Person::getSalary).reduce(Integer::sum);// 输出Optional[19937]System.out.println(reduce);} 16.收集终结方法
collect(Collector c)将流转化为其他形式接收一个Collector接口的实现
/*** 收集的练习*/Testpublic void test7(){ListPerson list new ArrayList();list.add(new Person(马化腾,25,3000));list.add(new Person(李彦宏,27,2545));list.add(new Person(雷军,35,4515));list.add(new Person(马云,55,9877));// 把年龄大于30岁的人转成一个list集合ListPerson collect list.stream().filter(person - person.getAge() 30).collect(Collectors.toList());// 遍历输出输出雷军和马云for (Person person : collect) {System.out.println(person);}System.out.println(----------);ListPerson list2 new ArrayList();list2.add(new Person(马化腾,25,3000));list2.add(new Person(李彦宏,27,2545));list2.add(new Person(雷军,35,4515));list2.add(new Person(马云,55,9877));// 把姓马的人转成Set集合SetPerson set list2.stream().filter(person - person.getName().startsWith(马)).collect(Collectors.toSet());// 输出马云和马化腾set.forEach(System.out::println);} 17.迭代iterate
可以使用Stream.iterate创建流值即所谓的无限流。
//Stream.iterate(initial value, next value)Stream.iterate(0, n - n 1).limit(5).forEach(x - System.out.println(x));输出
0
1
2
3
4 18.查看peek
peek接收的是一个Consumer函数peek 操作会按照 Consumer 函数提供的逻辑去消费流中的每一个元素同时有可能改变元素内部的一些属性
Testpublic void test1(){ListString collect Stream.of(one, two, three, four).filter(e - e.length() 3).peek(e - System.out.println(查看一下刚过滤出的值 e)).map(String::toUpperCase).peek(e - System.out.println(查看一下转大写之后的值 e)).collect(Collectors.toList());System.out.println(-----分割线-----);// 遍历过滤后的集合for (String s : collect) {System.out.println(s);}}输出
查看一下刚过滤出的值three
查看一下转大写之后的值THREE
查看一下刚过滤出的值four
查看一下转大写之后的值FOUR
-----分割线-----
THREE
FOUR Srtream流中方法的使用练习
/*** 1. 第一个队伍只要名字为3个字的成员姓名存储到一个新集合中。* 2. 第一个队伍筛选之后只要前3个人存储到一个新集合中。* 3. 第二个队伍只要姓张的成员姓名存储到一个新集合中。* 4. 第二个队伍筛选之后不要前2个人存储到一个新集合中。* 5. 将两个队伍合并为一个队伍存储到一个新集合中。* 6. 根据姓名创建 Person 对象存储到一个新集合中。* 7. 打印整个队伍的Person对象信息。*/
public class Demo3 {public static void main(String[] args) {//第一支队伍ArrayListString one new ArrayList();one.add(迪丽热巴);one.add(宋远桥);one.add(苏星河);one.add(石破天);one.add(石中玉);one.add(老子);one.add(庄子);one.add(洪七公);//第一个队伍只要名字为3个字的成员姓名存储到一个新集合中。//第一个队伍筛选之后只要前3个人存储到一个新集合中。StreamString stream one.stream();StreamString stream1 stream.filter(name - name.length() 3).limit(3);//第二支队伍ArrayListString two new ArrayList();two.add(古力娜扎);two.add(张无忌);two.add(赵丽颖);two.add(张三丰);two.add(尼古拉斯赵四);two.add(张天爱);two.add(张二狗);//第二个队伍只要姓张的成员姓名存储到一个新集合中。//第二个队伍筛选之后不要前2个人存储到一个新集合中。StreamString stream2 two.stream();StreamString stream3 stream2.filter(name - name.startsWith(张)).skip(2);//合并两个队伍StreamString concat Stream.concat(stream1, stream3);//把合并后的队伍根据姓名创建Person对象并存入新的集合中然后打印concat.map(name - new Person(name)).forEach(p - System.out.println(p));}
}
