使用parallelStream时，容易忽略的线程安全问题

痛定思痛。 2022-12-27 08:19 328阅读 0赞

当我们在使用parallelStream去开启多线程处理任务的时候，在需要得到最终处理结果会出问题。举个栗子。。。

public static void main(String[] args) throws InterruptedException {
            List<Integer> list = new ArrayList();
            List<Integer> list1 = new ArrayList();
            for (int i = 0; i < 100; i++) {
                list.add(i);
            }
            long startTime = System.currentTimeMillis();
            list.parallelStream().forEach(i -> {
    
                System.out.println(i);
                list1.add(i);
                    }
            );
            long endTime = System.currentTimeMillis();
            System.out.println((endTime - startTime)+ "ms");
            System.out.println(list1.size());
        }

运行结果：  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70][]  
可以看到本来应该是100000才对，少了四条，之前我错误的以为这是因为在打印size的时候，还有四条线程并没有执行完成，导致我们的结果是错误的，其实真正的问题是因为我使用线程不安全的arraylist导致的，多线程执行arraylist的add方法会有问题。在我们需要使用parallelStream处理后的结果的时候要特别注意。  
这时我们可以使用stream，stream会顺序执行  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 1]  
或者我们可以使用CopyOnWriteArrayList，它的add方法是线程安全的。  
parallelStream和Stream的效率比较：

public static void main(String[] args) throws InterruptedException {
            List<Integer> list = new ArrayList();
            for (int i = 0; i < 200000; i++) {
                list.add(i);
            }
            long startTime = System.currentTimeMillis();
            list.parallelStream().forEach(i -> {
    
                System.out.println(i);
                }
            );
            long endTime = System.currentTimeMillis();
            System.out.println("total "+(endTime - startTime)+ "ms");
        }

<table> 
 <thead> 
  <tr> 
   <th>type/records</th> 
   <th>100</th> 
   <th>1000</th> 
   <th>10000</th> 
   <th>100000</th> 
   <th>1000000</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>Stream</td> 
   <td>94ms</td> 
   <td>99ms</td> 
   <td>215ms</td> 
   <td>422ms</td> 
   <td>3296ms</td> 
  </tr> 
  <tr> 
   <td>parallelStream</td> 
   <td>111ms</td> 
   <td>113ms</td> 
   <td>169ms</td> 
   <td>708ms</td> 
   <td>1080ms</td> 
  </tr> 
 </tbody> 
</table>

可以明显的看到只有当数据达到一定量的时候，parallelStream才能够发挥出多线程的优势，数据量太少使用parallelStream反而会拖累效率，而且容易出现多线程安全的问题。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70]: /images/20221120/9b2eccdd719944f4b3535f1c4a9deeec.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzE3MDExNDIz_size_16_color_FFFFFF_t_70 1]: /images/20221120/cf7742cd195c4f80b07ce7d6bfb474a8.png