时间:2021-05-20
从集合到流
现在我们用代码来具体表示对某一集合进行迭代操作,我们希望定义一个Contact类来表示联系人,并将ContactList中所有String类型的联系人姓名全部包装进Contact类中:
List<Contact> contacts = new ArrayList<>();contactList.forEach(new Consumer<String>() { @Override public void accept(String s) { Contact contact = new Contact(); contact.setName(s); contacts.add(contact); }});接下来我们希望筛选出所有还能打通的联系人,将其放入一个有效联系人集合:
List<Contact> validContacts = new ArrayList<>();contacts.forEach(new Consumer<Contact>() { @Override public void accept(Contact c) { if (c.call()) validContacts.add(c); }});System.out.println(validContacts.size());可以看出,第一次操作我们将String类型的数据转换为Contact,第二次则对每一个Contact调用call()方法,筛选出返回结果为true的联系人并将其收集进另一个集合,最后我们统计出还能打通的联系人数目。
在此过程中,操作行为完全封闭在各个集合内部,无需引入任何外部变量。
从处理开始、进行到结束,对象在操作间如同一个有序序列在移动,这就是流的特征,即“移动中的数据”。
真正的流与集合大相径庭,其只表示一种“可选的有序值序列”,而“无需为这些值提供任何存储”,这就是为何Stream在Java8-API中被定义为接口而非一种类。
public interface Stream<T> extends BaseStream<T, Stream<T>> {}Stream<T>为对象的流,而DoubleStream、LongStream以及IntStream则为double、long以及int这三种基本类型的流。
现在我们再将第一次从String到Contact的映射用流的方式来重写:
Stream<Contact> contactStream = contactList.stream().map(s -> new Contact().setName(s));stream()从源中取得管道,表示流的开始。
map()接收管道中的流并对其进行某种变换,在本例中,我们将管道中的String映射成为Contact类,自此,String管道成为Contact管道。
我们可以将上一段代码拆分为:
Stream<String> stringStream = contactList.stream();Stream<Contact> contactStream1 = stringStream.map(s -> new Contact().setName(s));在基本搞清了流操作之后,我们现在一气呵成,直接使用流得到最终结果:
long validContactCounter = contactList.stream() .map(s -> new Contact().setName(s)) .filter(c -> c.call()) .count();可以看出,我们对流能够进行丰富的操作,过滤、计数、查找等等,在此不表。
小结
使用流的方式处理数据能够精简代码,同时突出了所要进行的操作,当然乍看起来有些难懂。
既然牺牲了些许可读性,但是作为交换条件,我们在这种顺序执行的流操作中,获得了两倍于相应的循环版本的性能。
同样,并行执行流操作对于大型数据集将产生非凡的效果。
本小节相关代码:
(Contact.java)
import java.util.Random;public class Contact { private String name; private long number; private Random random; public Contact() { random = new Random(); } public String getName() { return name; } public Contact setName(String name) { this.name = name; return this; } public long getNumber() { return number; } public Contact setNumber(long number) { this.number = number; return this; } public boolean call() { return random.nextBoolean(); }}(运行用)List<Contact> contacts = new ArrayList<>();contactList.forEach(new Consumer<String>() { @Override public void accept(String s) { Contact contact = new Contact(); contact.setName(s); contacts.add(contact); }});List<Contact> validContacts = new ArrayList<>();contacts.forEach(new Consumer<Contact>() { @Override public void accept(Contact contact) { if (contact.call()) validContacts.add(contact); }});System.out.println(validContacts.size());//--- Stream is coming ---//Stream<Contact> contactStream = contactList.stream().map(s -> new Contact().setName(s));//--- Break this code ---//Stream<String> stringStream = contactList.stream();Stream<Contact> contactStream1 = stringStream.map(s -> new Contact().setName(s));//--- All in one ---//long validContactCounter = contactList.stream() .map(s -> new Contact().setName(s)) .filter(c -> c.call()) .count();System.out.println(validContactCounter);以及运行结果:
3
3
以上所述是小编给大家介绍的Java Lambda表达式之从集合到流,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
什么是Lambda表达式,java8为什么使用Lambda表达式?“Lambda表达式”(lambdaexpression)是一个匿名函数,Lambda表达式基
快速回顾1.Lambda表达式:(参数)->{主体}Lambda表达式打开了函数式编程爱好者继续使用Java的大门。Lambda表达式需要零个或多个参数,这些参
本文实例讲述了Python学习笔记之lambda表达式用法。分享给大家供大家参考,具体如下:Lambda表达式使用Lambda表达式创建匿名函数,即没有名称的函
前言上一篇文章30分钟入门Java8之lambda表达式,我们学习了lambda表达式。现在继续Java8新语言特性的学习,今天,我们要学习的是默认方法和静态接
一、Lambda表达式简介Lambda表达式,是Java8的一个新特性,也是Java8中最值得学习的新特性之一。(另一个新特性是流式编程。)Lambda表达式,