多线程list.add()丢数据

Posted weiweiwei

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了多线程list.add()丢数据相关的知识,希望对你有一定的参考价值。

问题:

根据项目业务需求需要统计数据传到前台以图表显示,每天数据量大概20万多,但是每次统计只能统计出10万的数据量,出现数据丢失。

原因:

该接口在之前一次优化时加了多线程,但是数据汇总用的仍是ArrayList,ArrayList线程不安全,当一条线程执行list.add()的时候会出现被另一条线程的值覆盖,比如线程A对list进行add,携带的size是n,同时线程B也进行add操作,携带的size也是n,所以ArrayList没有达到扩容的条件,A的值应该放在ArrayList的第n位,但是B的值也将放在第n位,覆盖了A的值,导致数据丢失。

ArrayList add()部分源码解读:

技术图片

 

 解决方案:

(1)Vector:线程安全,但不推荐使用,因为加了锁,导致性能降低。
(2)List<String> list=Collections.synchronizedList(new ArrayList<>());使用Collections工具类将线程不安全的集合转成线程安全的集合,
(3)java.concurrent.CopyOnWriteArrayList(写入时复制思想),做add操作时加了锁ReentrantLock。

 



以上是关于多线程list.add()丢数据的主要内容,如果未能解决你的问题,请参考以下文章

在 Flink 算子中使用多线程如何保证不丢数据?

多线程通信

Java多线程中线程间的通信

多线程与对象的生命周期管理

多线程9--- 线程间非实时通信--锁的wait与notify

java里有没有专门判断List里有重复的数据