ArrayList不是并发安全的?那么在高并发环境下怎么使用集合
生活随笔
收集整理的這篇文章主要介紹了
ArrayList不是并发安全的?那么在高并发环境下怎么使用集合
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
目錄
寫在前面
一、ArrayList并發(fā)不安全
二、集合類Set并發(fā)不安全
三、Map線程不安全
寫在前面
? ? 很多小伙伴使用ArrayList、HashMap等集合類,大多數(shù)情況下都不是用在多線程環(huán)境下的。
? ? 那么,多線程環(huán)境下是否仍然可以使用ArrayList、HashMap等集合類呢?
? ? 答案:不可以哦。
一、ArrayList并發(fā)不安全
1.驗證ArrayList并發(fā)不安全,以及解決方案
import java.util.*; import java.util.concurrent.CopyOnWriteArrayList;public class ArrayListNotSafeDemo {public static void main(String[] args) {// 1.ArrayList線程不安全的示例//List<String> list = new ArrayList<>();// 2.Vector 是線程安全的,但是太古老了//List<String> list = new Vector<>();// 3.使用Collections類生成一個線程安全的ArrayList//List<String> list = Collections.synchronizedList(new ArrayList<String>());// 4.CopyOnWriteArrayList 寫時復制,讀寫分離的思想,線程安全CopyOnWriteArrayList<String> list = new CopyOnWriteArrayList<>();for (int i = 0; i < 30; i++) {new Thread(() ->{// java.util.ConcurrentModificationExceptionlist.add(UUID.randomUUID().toString().substring(0, 8));// 多線程下會造成數(shù)據(jù)問題。System.out.println(list);}).start();}/*** 1.故障現(xiàn)象* java.util.ConcurrentModificationException** 2.導致原因* ArrayList線程不安全** 3.解決方案* Vector* Collections.synchronizedList* CopyOnWriteArrayList*/} }2.CopyOnWriteArrayList解析? ? 寫時復制? ? 讀寫分離
/* CopyOnWriteArrayList的add方法 添加時,1.先復制,2.再添加,3.再換引用寫時復制:CopyOnWrite容器即寫時復制的容器。往一個容器添加元素的時候,不直接往當前容器Object[]添加,而是先將當前容器Object[]進行copy,復制出一個新的容器Object[] newElements,然后新的容器Object[] newElements里添加元素,添加完元素之后,再將原容器的引用指向新的容器setArray(newElements);。這樣做的好處是可以對CopyOnWrite容器進行并發(fā)的讀,而不需要加鎖,因為當前容器不會添加任何元素。 所以CopyOnWrite容器也是一種讀寫分離的思想,讀和寫不同的容器。 */public boolean add(E e) {final ReentrantLock lock = this.lock;lock.lock();try {Object[] elements = getArray();int len = elements.length;Object[] newElements = Arrays.copyOf(elements, len + 1);newElements[len] = e;setArray(newElements);return true;} finally {lock.unlock();} }二、集合類Set并發(fā)不安全
import java.util.Set; import java.util.UUID; import java.util.concurrent.CopyOnWriteArraySet;public class SetNotSafeDemo {public static void main(String[] args) {// 1.并發(fā)不安全//Set<String> set = new HashSet<>();// 2.Collections.synchronizedSet//Set<String> set = Collections.synchronizedSet(new HashSet<>());// 3. CopyOnWriteArraySet 底層其實還是一個CopyOnWriteArrayListSet<String> set = new CopyOnWriteArraySet();for (int i = 0; i < 30; i++) {new Thread(() ->{// java.util.ConcurrentModificationExceptionset.add(UUID.randomUUID().toString().substring(0, 8));// 多線程下會造成數(shù)據(jù)問題。System.out.println(set);}).start();}/*** 1. HashSet底層就是一個HashMap。* 2. HashSet的add方法只放一個參數(shù),key就是這個參數(shù),value是一個Object,是恒定的。*/} }三、Map線程不安全
import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap;public class MapNotSafeDemo {public static void main(String[] args) {// 1.線程不安全//Map<String, String> map = new HashMap<>();// 2.Collections.synchronizedMap//Map<String, String> map = Collections.synchronizedMap(new HashMap<>());// 3.ConcurrentHashMap是線程安全的,分段鎖,16段Map<String, String> map = new ConcurrentHashMap<>();for (int i = 0; i < 30; i++) {new Thread(() ->{// java.util.ConcurrentModificationExceptionmap.put(Thread.currentThread().getName(), UUID.randomUUID().toString().substring(0, 8));// 多線程下會造成數(shù)據(jù)問題。System.out.println(map);}).start();}} }總結
以上是生活随笔為你收集整理的ArrayList不是并发安全的?那么在高并发环境下怎么使用集合的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 我知道乐观锁,但是我的确不知道CAS啊,
- 下一篇: 深挖java线程池