集合的常用线程安全实现类使用及源码分析

Posted 2022-12-09 若曦`

• 1. 并发修改异常问题的产生
• 2. CopyOnWriteArrayList
• • (1) 源码分析
  • • ① 构造函数
    • ② add()方法的实现
  • (2) 使用
• 2. CopyOnWriteArraySet
• • (1) 源码分析
  • • ① 构造函数
    • ② add()方法的实现
  • (2) 使用
• 3. ConcurrentHashMap

1. 并发修改异常问题的产生

当多个线程同时去操作一个数据/集合的时候，就会产生并发修改异常，因为同一数据不允许同时被多个线程操作

代码示例
创建一个ArrayList，开启一百个线程，每个都往集合里添加一个a，结束后打印输出ArrayList的大小

public static void main(String[] args) 
        List<String> list = new ArrayList<>();
        for (int i = 0; i < 100; i++) 
            new Thread(()->
                //向集合中添加数据
                list.add("a");
                //输出每次线程添加结束后的数据
                System.out.println(list);
            ).start();
        
        try 
            //主线程休眠0.1秒，目的是等待其他线程执行完毕
            Thread.sleep(100);
         catch (InterruptedException e) 
            e.printStackTrace();
        
        System.out.println("=====");
        //输出加完集合后的大小
        System.out.println(list.size());
    

出现了并发修改异常，且最后的集合大小也不是100，说明也造成了数据丢失的情况

2. CopyOnWriteArrayList

集合的线程安全类，都是为了解决ConcurrentModificationException(并发修改异常) 和数据丢失的问题

(1) 源码分析

① 构造函数

② add()方法的实现

(2) 使用

List<String> list = new CopyOnWriteArrayList<>();

将ArrayList改为CopyOnWriteArrayList就行，其他的不变

没有出现并发修改异常，也没有出现数据丢失

2. CopyOnWriteArraySet

(1) 源码分析

① 构造函数

② add()方法的实现

add()方法调用 addIfAbsent() (缺席添加) (如果不存在则添加)

addIfAbsent()方法 (缺席添加)

(2) 使用

Set<String> set = new CopyOnWriteArraySet<>();

其余和HashSet的使用一样

3. ConcurrentHashMap

ConcurrentHashMap的东西太多不想写了，建议去看下大佬写的这篇博客，很详细

博客地址