Java 8 裡面的stream 有序列流和並行流之分。

說高階的stream就是那個並行流。下面是那個並行流的簡單實現。只要是繼承Collection類的都可以這麼用。

list.stream().parallel()
list.parallelStream()

先看程式碼和執行結果，再解釋一下，這個並行序列流之間的差別。

package com.lxk.lambdaTest;

import com.google.common.collect.Lists;

import java.util.List;

/**
 * 測試效能(Java 8 的迴圈和Java 7 的迴圈耗時的對比測試)
 * <p>
 * Created by lxk on 2017/8/31
 */
public class Performance {
    public static void main(String[] args) {
        List<String> list = getLoopList();
        normalBeforeLoop(list);
        normalAfterLoop(list);
        notNormalAfterLoop(list);
    }

    private static void notNormalAfterLoop(List<String> list) {
        long a = System.currentTimeMillis();
        list.stream().parallel().forEach(System.out::print);
        System.out.println(" list.stream().parallel().forEach 執行耗時 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
    }

    private static void normalAfterLoop(List<String> list) {
        long a = System.currentTimeMillis();
        list.stream().forEach(System.out::print);
        System.out.println(" list.stream().forEach 執行耗時 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
        a = System.currentTimeMillis();
        list.forEach(System.out::print);
        System.out.println(" list.forEach 執行耗時 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
    }

    private static void normalBeforeLoop(List<String> list) {
        long a = System.currentTimeMillis();
        for (String s : list) {
            System.out.print(s);
        }
        System.out.println(" for each 執行耗時 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
    }

    private static List<String> getLoopList() {
        List<String> list = Lists.newArrayList();
        for (int i = 0; i < 10000; i++) {
            list.add("item " + i);
        }
        return list;
    }
}
 

好，關於，那個並行和序列的流的差別，可以看到啦。

並行的流，在迴圈的時候，就不是 1 - 9999 挨著輸出。而是，看多核的心情。