Stream的顺序流与并行流

/**
 * @auther hhh
 * @date 2019/1/2 22:52
 * @description
 */
public class StreamAPI2 {
    /**
     * 流的特性：支持并行流与顺序流
     * 并行流：多个线程同时运行
     * 顺序流：使用主线程，单线程
     */
    public static void main(String[] args) {
        Optional<Integer> optionalInteger = Stream.iterate(1, x -> x+1).limit(200).peek(x->{
                    System.out.println(Thread.currentThread().getName());
                }
        ).max(Integer::compareTo);//输出 main main Optional[200]，始终使用的是主线程，说明流默认是顺序流，使用的是主线程
        System.out.println(optionalInteger);
        Optional<Integer> optional = Stream.iterate(1, x -> x+1).limit(200).peek(x->{
                    System.out.println(Thread.currentThread().getName());
                }
        ).parallel().max(Integer::compareTo);//加上 .parallel()可以将其修改成并行流，内部以多线程并行执行任务的方式执行
        //输出：说明有多个线程在并行执行
        //ForkJoinPool.commonPool-worker-2
        //ForkJoinPool.commonPool-worker-3
        //Optional[200]
        System.out.println(optional);


        //将并行流变成顺序流 加上.sequential()
        Optional<Integer> optional1 = Stream.iterate(1, x -> x+1).limit(200).peek(x->{
                    System.out.println(Thread.currentThread().getName());
                }
        ).parallel().sequential().max(Integer::compareTo);
        //设置lambda表达式并行的线程数量，使用parallelism
        //设置启动变量:加上这个参数设置 java.util.concurrent.ForkJoinPool.common.parallelism
        //设置为5个线程数量
        System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism","5");
    }
}