P16-18
程式清單1-4 collecting/CollectingResults.java

1. 程式碼
2. 專案結構
3. 分析
4. 重要API

1.程式碼

import java.io.*;
import java.nio.charset.*;
import java.nio.file.*;
import java.util.*;
import java.util.stream.*;

public class CollectingResults
{
   public static Stream<String> noVowels() throws IOException
   {
   //讀取alice30.txt
 
檔案中所有內容並賦給contents字串
      String contents = new String(Files.readAllBytes(
            Paths.get("../gutenberg/alice30.txt")),
            StandardCharsets.UTF_8);

   //將contents中字串切割成單詞並存入wordList列表
      List<String> wordList = Arrays.asList(contents.split("\\PL+"));

    //建立wordList列表對應的流並賦給words字串流
      Stream<String> words = wordList.stream
 
();

    //將words對映為一個“將母音字母全部改為空”的字串流stream並返回
      return words.map(s -> s.replaceAll("[aeiouAEIOU]", ""));
   }

   public static <T> void show(String label, Set<T> set)
   {
   //列印set所屬型別
      System.out.print(label + ": " + set.getClass().getName());

    //列印set對應流的元素（以逗號分隔）
      System.out
 
.println("["
            + set.stream().limit(10).map(Object::toString)
                  .collect(Collectors.joining(", ")) + "]");
   }

   public static void main(String[] args) throws IOException
   {
   //迭代遍歷流裡前十個元素並列印。從0開始，每次加1
      Iterator<Integer> iter = Stream.iterate(0, n -> n + 1).limit(10)
            .iterator();
      while (iter.hasNext())
         System.out.println(iter.next());

    //迭代流裡前十個元素並賦給object陣列numbers，列印陣列首地址
      Object[] numbers = Stream.iterate(0, n -> n + 1).limit(10).toArray();
      System.out.println("Object array:" + numbers); // Note it's an Object[] array

      try
      {
      //列印numbers陣列的第一個元素
         Integer number = (Integer) numbers[0]; // OK
         System.out.println("number: " + number);

         System.out.println("The following statement throws an exception:");
         Integer[] numbers2 = (Integer[]) numbers; // Throws exception
      }
      catch (ClassCastException ex)
      {
      //列印異常資訊
         System.out.println(ex);
      }

    //迭代並構造流裡前十個元素賦給Integer陣列numbers，列印陣列首地址
      Integer[] numbers3 = Stream.iterate(0, n -> n + 1).limit(10)
         .toArray(Integer[]::new);
      System.out.println("Integer array: " + numbers3); // Note it's an Integer[] array

      Set<String> noVowelSet = noVowels()
            .collect(Collectors.toSet());
      show("noVowelSet", noVowelSet);

      TreeSet<String> noVowelTreeSet = noVowels().collect(
            Collectors.toCollection(TreeSet::new));
      show("noVowelTreeSet", noVowelTreeSet);

      String result = noVowels().limit(10).collect(
            Collectors.joining());
      System.out.println("Joining: " + result);
      result = noVowels().limit(10)
            .collect(Collectors.joining(", "));
      System.out.println("Joining with commas: " + result);

      IntSummaryStatistics summary = noVowels().collect(
            Collectors.summarizingInt(String::length));
      double averageWordLength = summary.getAverage();
      double maxWordLength = summary.getMax();
      System.out.println("Average word length: " + averageWordLength);
      System.out.println("Max word length: " + maxWordLength);
      System.out.println("forEach:");
      noVowels().limit(10).forEach(System.out::println);
   }
}

alice30.txt在這裡就不貼出了，讀者可以自己隨意寫個文字文件進行測試。

2.專案結構

3.分析

先講一下兩個靜態方法：

public static Stream<String> noVowels() throws IOException
   {
      String contents = new String(Files.readAllBytes(
            Paths.get("../gutenberg/alice30.txt")),
            StandardCharsets.UTF_8);
      List<String> wordList = Arrays.asList(contents.split("\\PL+"));
      Stream<String> words = wordList.stream();
      return words.map(s -> s.replaceAll("[aeiouAEIOU]", ""));
   }

noVowels()方法：從alice30.txt中讀取字元內容，分隔為單詞並去除母音字母后返回流Stream<String>。
words.map(s -> s.replaceAll("[aeiouAEIOU]", ""))將words中的元素一一對映為新的元素，並整合為新流。[aeiouAEIOU]是正則表示式，匹配母音字母。

public static <T> void show(String label, Set<T> set)
   {
      System.out.print(label + ": " + set.getClass().getName());
      System.out.println("["
            + set.stream().limit(10).map(Object::toString)
                  .collect(Collectors.joining(", ")) + "]");
   }

show(String label, Set<T> set)方法：列印label，列印set中前十個元素（以逗號分隔）。
getClass()，getName()利用反射機制，是Object方法。
collect(Collectors.joining(", "))方法：收集流中的元素並以逗號分隔，返回String型別。

回到main函式：

以下：

try
      {
         Integer number = (Integer) numbers[0]; // OK
         System.out.println("number: " + number);
         System.out.println("The following statement throws an exception:");
         Integer[] numbers2 = (Integer[]) numbers; // Throws exception
      }
      catch (ClassCastException ex)
      {
         System.out.println(ex);
      }

這裡解釋一下這句程式碼：Integer[] numbers2 = (Integer[]) numbers; // Throws exception
numbers是Object陣列物件，而Object[]並不是Integer[]的父類，因此強制轉型後丟擲ClassCastException型別匹配異常。
main函式其餘部分，請參照重要API佐證理解。

4.重要API

java.util.stream.BaseStream 8

Iterator<T> iterator()
產生一個用於獲取當前流中各個元素的迭代器。這是一種終結操作。

java.util.stream.BaseStream 8

Iterator<T> iterator()
產生一個用於獲取當前流中各個元素的迭代器。這是一種終結操作。

java.util.stream.Stream 8

void forEach(Consumer<? super T>action)
在流的每個元素上呼叫action。這是一種終結操作。

Object[] toArray()
<A>A[] toArray(IntFunction<A[]> generator)
產生一個物件陣列，或者在將引用A[]::new傳遞給構造器時，返回一個A型別的陣列。這些操作都是終結操作。

<R,A> R collect(Collector<? super T,A,R> collector)
使用給定的收集器來收集當前流中的元素。Collectors類有用於多種收集器的工廠方法。

java.util.stream.Collectors 8

static <T> Collector<T,?,List<T>> toList()
static <T> Collector<T,?,Set<T>> toSet()
產生一個將元素收集到列表或集中的收集器。

static <T,C extends Collection<T>> Collector<T,?,C> toCollection(Supplier<C> collectionFactory)
產生一個將元素收集到任何集合中的收集器。可以傳遞一個諸如Treeset::new的構造器引用。

static Collector<CharSequence,?,String> joining()
static Collector<CharSequence,?,String> joining(CharSequence delimiter)
static Collector<CharSequence,?,String> joining(CharSequence delimiter, CharSequence prefix, CharSequence suffix)
產生一個連線字串的收集器。分隔符會置於字串之間，而第一個字串之前可以有字首，最後一個字串之後可以有後綴。如果沒有指定，那麼它們都為空。

static <T> Collector<T,?,IntSummaryStatistics> summarizingint(ToIntFunction<?super T>mapper
產生能夠生成（Int|Long|Double）SummaryStatistics物件的收集器，通過它可以獲得將mapper應用於每個元素後所產生的結果的個數、總和、平均值、最大值和最小值。

如有謬誤或不完善之處，懇請斧正。