首页 > 其他 > 详细

ConcurrentModificationException错误的一次解决经历

时间:2019-06-20 21:34:20      阅读:148      评论:0      收藏:0      [点我收藏+]

测试环境上有时调用满减接口会抛错,通常是出现在店铺比较多的时候.

看了一下错误日志,提示我们是ConcurrentModificationException错误.这个错误很明显,是ArrayList在迭代的时候同时对其进行了修改时抛出的异常.

看了一下代码.大致如下:

List a = Lists.newArrayList();

b.stream().foreach{

  .......

  if (true){

     a.add(c);

  }

  for(A a: a){

    a.add(c);

  }

}

大致就是这个意思.在stream中对A进行了遍历及add操作.

而我们知道stream流是有可能隐式的开启多线程的.那么原因就很明显了,由于店铺较多,导致虚拟机选择开启多线程,从而导致了此问题.

我们知道ArrayList是线程不安全的,那么我们把这个集合改成线程安全的不就解决了么.

查了一下,发现CopyOnWriteArrayList很符合我们的要求.

简介就不说了,百度一下就知道了.我们看一下他的add方法.

技术分享图片

大致说明一下,首先类里面有一个ReentrantLock,用来加锁.

进入add方法后先加个锁,然后获得CopyOnWriteArrayList内层的数组,拷贝一份,把新元素加到新数组后面,然后把CopyOnWriteArrayList内层的数组指向新数组.解锁.

所以我们可以知道,如果线程A运行到把新元素加到新数组后面之类的地方,还没有指向新数组的时候,线程B去读取数据,读取到的仍然是原来的值.

对于我的这个场景来说,重复是可以接受的,所以就这样就OK了,如果重复数据是不能接受的,那么我们可以在stream操作结束后进行一次去重.

 

ConcurrentModificationException错误的一次解决经历

原文:https://www.cnblogs.com/tyoutetu/p/11061187.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!