現(xiàn)在我們用代碼來具體表示對(duì)某一集合進(jìn)行迭代操作，我們希望定義一個(gè)Contact類來表示聯(lián)系人，并將ContactList中所有String類型的聯(lián)系人姓名全部包裝進(jìn)Contact類中：
|
1
2
3
4
5
6
7
8
9
|
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); }}); |
接下來我們希望篩選出所有還能打通的聯(lián)系人，將其放入一個(gè)有效聯(lián)系人集合：
|
1
2
3
4
5
6
7
8
9
|
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類型的數(shù)據(jù)轉(zhuǎn)換為Contact，第二次則對(duì)每一個(gè)Contact調(diào)用call()方法，篩選出返回結(jié)果為true的聯(lián)系人并將其收集進(jìn)另一個(gè)集合，最后我們統(tǒng)計(jì)出還能打通的聯(lián)系人數(shù)目。
在此過程中，操作行為完全封閉在各個(gè)集合內(nèi)部，無需引入任何外部變量。
從處理開始、進(jìn)行到結(jié)束，對(duì)象在操作間如同一個(gè)有序序列在移動(dòng)，這就是流的特征，即“移動(dòng)中的數(shù)據(jù)”。
真正的流與集合大相徑庭，其只表示一種“可選的有序值序列”，而“無需為這些值提供任何存儲(chǔ)”，這就是為何Stream在Java8-API中被定義為接口而非一種類。
|
1
|
public interface Stream<T> extends BaseStream<T, Stream<T>> {} |
Stream<T>為對(duì)象的流，而DoubleStream、LongStream以及IntStream則為double、long以及int這三種基本類型的流。
現(xiàn)在我們?cè)賹⒌谝淮螐腟tring到Contact的映射用流的方式來重寫：
|
1
|
Stream<Contact> contactStream = contactList.stream().map(s -> new Contact().setName(s)); |
stream()從源中取得管道，表示流的開始。
map()接收管道中的流并對(duì)其進(jìn)行某種變換，在本例中，我們將管道中的String映射成為Contact類，自此，String管道成為Contact管道。
我們可以將上一段代碼拆分為：
|
1
2
|
Stream<String> stringStream = contactList.stream();Stream<Contact> contactStream1 = stringStream.map(s -> new Contact().setName(s)); |
在基本搞清了流操作之后，我們現(xiàn)在一氣呵成，直接使用流得到最終結(jié)果：
|
1
2
3
4
5
|
long validContactCounter = contactList.stream() .map(s -> new Contact().setName(s)) .filter(c -> c.call()) .count(); |
可以看出，我們對(duì)流能夠進(jìn)行豐富的操作，過濾、計(jì)數(shù)、查找等等，在此不表。
小結(jié)
使用流的方式處理數(shù)據(jù)能夠精簡(jiǎn)代碼，同時(shí)突出了所要進(jìn)行的操作，當(dāng)然乍看起來有些難懂。
既然犧牲了些許可讀性，但是作為交換條件，我們?cè)谶@種順序執(zhí)行的流操作中，獲得了兩倍于相應(yīng)的循環(huán)版本的性能。
同樣，并行執(zhí)行流操作對(duì)于大型數(shù)據(jù)集將產(chǎn)生非凡的效果。
本小節(jié)相關(guān)代碼：
（Contact.java）
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
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(); }}（運(yùn)行用） |
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
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); |
以及運(yùn)行結(jié)果：
3
3
以上所述是小編給大家介紹的Java Lambda表達(dá)式之從集合到流，希望對(duì)大家有所幫助，如果大家有任何疑問請(qǐng)給我留言，小編會(huì)及時(shí)回復(fù)大家的。在此也非常感謝大家對(duì)服務(wù)器之家網(wǎng)站的支持！
原文鏈接：http://www.cnblogs.com/hwding/p/6379897.html
