ArrayList不安全 ArrayList中的add方法沒有synchronized修飾,是不安全的
下面代碼運行結果(異常 java.util.ConcurrentModificationException):
import java.util.ArrayList; import java.util.List; import java.util.UUID; /**
- @author zkw
- @Description list不安全 */ public class ThreadList { public static void main(String[] args) { List list = new ArrayList<>(); for (int i = 0; i < 30; i++) { new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,8)); System.out.println(list); }, i+"").start(); } } } 一鍵獲取完整項目代碼 java
解決方法 使用Vector (已過時) 使用的是synchronized機制
使用Collections.synchronizedList()方法修飾ArrayList (性能不高)
Collections中還有synchronizedMap和synchronizedSet的方法,可以修飾線程不安全的HashSet,HashMap
使用java.util.concurrent.CopyOnWriteArrayList(推薦)使用的是lock鎖
使用CopyOnWriteArrayList
底層使用的是ReentrantLock可重用鎖
下面給出CopyOnWriteArrayList 的 add源碼
final transient ReentrantLock lock = new ReentrantLock();
/** * Appends the specified element to the end of this list. * * @param e element to be appended to this list * @return {@code true} (as specified by {@link Collection#add}) */ 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(); } } 一鍵獲取完整項目代碼 java
案例運行結果:
案例源碼:
import java.util.*; import java.util.concurrent.CopyOnWriteArrayList; /**
- @author zkw
- @Description list不安全 */ public class ThreadList { public static void main(String[] args) { List list = new CopyOnWriteArrayList<>(); for (int i = 0; i < 30; i++) { new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,8)); System.out.println(list); }, i+"").start(); } } } 一鍵獲取完整項目代碼 java
CopyOnWriteArrayList解析 CopyOnWriteArrayList 利用的是讀寫分離的思想,讀和寫的是不同的容器
底層使用的是一個Object數組,每次新添加元素的時候利用的是Arrays.copyOf來創建一個新數組達到擴容效果
使用的是ReentrantLock來保證線程安全
寫時複製 Copyonwrite容器即寫時複製的容器。往一個容器添加元素的時候,不直接往當前容漲object[]添加,而是先將當前容器 object[ ]進行copy,複製出一個新的容器object[ ] newELements,然後新的容器object[ ] newELements裏添加元素,添加 完元素之後, 再將原容器的引用指向新的容器setArray(newELements);。這樣做的好處是可以對Copyonwrite容器進行併發的讀,而不需 要加鎖,因為當前容器不會添加任何元素。所以Copyonwdrite容器也是一種讀寫分離的思想,讀和寫不同的容器。
final transient ReentrantLock lock = new ReentrantLock();
private transient volatile Object[] array; /** * Appends the specified element to the end of this list. * * @param e element to be appended to this list * @return {@code true} (as specified by {@link Collection#add}) */ 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); //將新容器設置為該list的容器 return true; } finally { lock.unlock(); } } 一鍵獲取完整項目代碼 java
———————————————— 版權聲明:本文為CSDN博主「向着五星的方向」的原創文章,遵循CC 4.0 BY-SA版權協議,轉載請附上原文出處鏈接及本聲明。 原文鏈接:https://blog.csdn.net/qq_69748833/article/details/137060999