ArrayList线程不安全例子:
public class ListTest { public static void main(String[] args) { List<String> list = Collections.synchronizedList(new ArrayList<>()); // List<String> list = new Vector<>(); // List<String> list = Collections.synchronizedList(new ArrayList<>()); for (int i = 0; i < 20; i++) { new Thread(()->{ list.add(UUID.randomUUID().toString().substring(0,8)); list.forEach(System.out::println); }).start(); } } }
报错ConcurrentModificationException:
解决:
使用 Vector或者Collections.synchronizedList()方法
使用List<String> list = new CopyOnWriteArrayList<>();
来看看这个CopyOnWriteArrayList.这个是写时复制,读写分离的。
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(); } }
final void setArray(Object[] a) { array = a; }
读的时候不加锁。
set同理。也有CopyOnWriteArraySet
public class ListTest { public static void main(String[] args) { Set<String> set = new CopyOnWriteArraySet<>(); for (int i = 0; i < 20; i++) { new Thread(()->{ set.add(UUID.randomUUID().toString().substring(0,8)); set.forEach(System.out::println); }).start(); } } }
但是CopyOnWriteArraySet实际上是CopyOnWriteArrayList:
Map用ConcurrentHashMap, 数组+链表,如果长度大于8,链表成红黑树。