起源:blog.csdn.net/li_canhui/article/details/91393247

在多线程环境下,要应用线程平安的汇合,比方,ConcurrentHashMap是线程平安的HashMap,CopyOnWriteArrayList是线程平安的ArrayList。那么HashSet对应的线程平安汇合,是什么呢?java有没有提供默认实现呢?

在java的concurrent包中,我找到了CopyOnWriteArraySet,那么它是线程平安的吗?上面是测试代码。

public static void main(String[] args) {    Set<String> set = new CopyOnWriteArraySet<>();    ExecutorService service = Executors.newFixedThreadPool(12);    int times = 10000;    AtomicInteger flag = new AtomicInteger(0);    for(int i = 0; i < times; i ++){        service.execute(()->{            set.add("a" + flag.getAndAdd(1));        });    }    service.shutdown();    try {        service.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS);    }catch (Exception e){        e.printStackTrace();    }    System.out.println(set.size());}

通过屡次执行,后果都是10000。能够阐明,CopyOnWriteArraySet是线程平安的Set。另外,关注公众号Java技术栈,在后盾回复:面试,能够获取我整顿的 Java 系列面试题和答案,十分齐全。

那么CopyOnWriteArraySet是如何保障写入时的线程平安呢?以下是CopyOnWriteArraySet的add源码。

public boolean add(E e) {    return al.addIfAbsent(e);}public boolean addIfAbsent(E e) {    Object[] snapshot = getArray();    return indexOf(e, snapshot, 0, snapshot.length) >= 0 ? false :        addIfAbsent(e, snapshot);}private static int indexOf(Object o, Object[] elements,                           int index, int fence) {    if (o == null) {        for (int i = index; i < fence; i++)            if (elements[i] == null)                return i;    } else {        for (int i = index; i < fence; i++)            if (o.equals(elements[i]))                return i;    }    return -1;}private boolean addIfAbsent(E e, Object[] snapshot) {    final ReentrantLock lock = this.lock;    lock.lock();    try {        Object[] current = getArray();        int len = current.length;        if (snapshot != current) {            // Optimize for lost race to another addXXX operation            int common = Math.min(snapshot.length, len);            for (int i = 0; i < common; i++)                if (current[i] != snapshot[i] && eq(e, current[i]))                    return false;            if (indexOf(e, current, common, len) >= 0)                    return false;        }        Object[] newElements = Arrays.copyOf(current, len + 1);        newElements[len] = e;        setArray(newElements);        return true;    } finally {        lock.unlock();    }}

从源码能够看出,CopyOnWriteArraySet底层采纳了CopyOnWriteArrayList数据结构来实现。在add元素时,采纳的是可重入锁来实现线程平安。

近期热文举荐:

1.1,000+ 道 Java面试题及答案整顿(2021最新版)

2.别在再满屏的 if/ else 了,试试策略模式,真香!!

3.卧槽!Java 中的 xx ≠ null 是什么新语法?

4.Spring Boot 2.5 重磅公布,光明模式太炸了!

5.《Java开发手册(嵩山版)》最新公布,速速下载!

感觉不错,别忘了顺手点赞+转发哦!