zoukankan      html  css  js  c++  java
  • list.stream().parallel() 并行流

    https://blog.csdn.net/u011001723/article/details/52794455/  :  parallel()其实就是一个并行执行的流.它通过默认的ForkJoinPool,可能提高你的多线程任务的速度.

    https://www.cnblogs.com/strivelearn/p/6005649.html   :并发与并行的区别

    Java 8 lambda stream forEach parallel 等循环与Java 7 for each 循环耗时测试: 转自:https://blog.csdn.net/qq_27093465/article/details/77770479

    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 挨着输出。而是,看多核的心情。

  • 相关阅读:
    构建之法阅读笔记
    10个操作数的随机四则运算测试
    poj 1742 Coins (动态规划,背包问题)
    第二周进度报告
    蓝桥杯 2015年省赛最后一题 生命之树(树形dp)
    蓝桥杯 ALGO-108 最大体积 (动态规划)
    蓝桥杯 algo——6 安慰奶牛 (最小生成树)
    蓝桥杯 algo_5 最短路 (bellman,SPFA)
    蓝桥杯 ALGO-4 结点选择 (树形动态规划)
    软件工程——评价搜狗拼音输入法
  • 原文地址:https://www.cnblogs.com/hahajava/p/9683240.html
Copyright © 2011-2022 走看看