map 结合并行流 parallelStream进行遍历

ゞ浴缸里的玫瑰 2024-04-01 17:02 34阅读 0赞

> 业务场景中不乏需要将数据转换成map哈希映射结构，然后对其进行遍历数据处理分析，下面我们讲下用并行流方式来遍历map，**一定程度上提高数据遍历处理效率**

Stream 有串行和并行两种，串行 Stream 上的操作是在一个线程中依次完成，而并行 Stream 则是在多个线程上同时执行。一定程度上效率比串行高。

/**
     * java遍历map的多种方法
     * 1、普通的循环遍历
     * 2、jdk8以上的新特性
     *
     */
    public class Map {
        @Test
        public void test1() {
            map.forEach((key, value) -> {
                System.out.println(key + "=" + value);
            });
        }
    
        /**
         * 多线程并行执行
         */
        @Test
        public void test2() {
            map.keySet().parallelStream().forEach(key -> {
                System.out.println(key + "=" + map.get(key));
            });
        }
    
        /**
         * 串行执行
         */
        @Test
        public void test3() {
            map.keySet().stream().forEach(key -> {
                System.out.println(key + "=" + map.get(key));
            });
        }
    
    
        /**
         * *********************************************
         * 以下为java常规遍历map的方式
         * 1.优先选择foreach
         * 2.遍历List的同时要移除元素推荐使用iterator
         */
        @Test
        public void test4() {
            Iterator<String> iterator = map.keySet().iterator();
            while (iterator.hasNext()) {
                String next = iterator.next();
                System.out.println(next + "=" + map.get(next));
            }
        }
    
        @Test
        public void test5() {
            for (Map.Entry<String, String> entry : map.entrySet()) {
                System.out.println(entry.getKey() + "=" + entry.getValue());
            }
        }
    
        @Test
        public void test6() {
            for (String key : map.keySet()) {
                System.out.println( key + map.get(key));
            }
        }
    
        //只能遍历value的值
        @Test
        public void tes7t() {
            for (String value : map.values()) {
                System.out.println(value);
            }
        }
    }

**注意：parallelStream是线程不安全的**

解决并行流的线程安全问题：多线程下，使用并行流会有线程安全的问题。根据需要进行不同的处理：

*  使用同步代码块 synchronized （比如使用forEach循环处理时）
 *  使用线程安全的集合 Vector、Collections.synchronizedList(list)
 *  调用Stream流的 collect/toArray 方法