面试题18解析-同步容器

本文涉及的产品
容器镜像服务 ACR,镜像仓库100个 不限时长
简介: 请说明一下同步容器CopyOnWriteArrayList/ConcurrentHashMap/SynchronizedMap(Collections定义的内部类)的区别及它们的应用场景?

本文阅读大概需要18分钟。


这个题目主要考查同步容器相关的问题。


在Java多线程开发中,往往需要java中常用的容器作为共享资源来使用,如Array、List、Hashmap、Set等。但是基本的容器在多线程下进行并发操作是有问题,需要进行加锁才能保证多线程共享容器的线程安全(Thread Safe)。为了简化java多线程开发,JDK中提供了一些线程安全容器,使得程序员在开发多线程应用时,可以将更多的精力放在程序逻辑上,而不是错综复杂的锁处理上。但JDK中不同的并发容器类,拥有不同的性质和应用场景,这里我们就来分析一下三种线程安全的并发容器:ConcurrentHashMap、SychronizedMap和CopyOnWriteArrayList。


一三种容器的并发说明


首先说明一下这三种容器代表的是三类容器,我们这里只讨论这三类容器在应对并发处理上区别,并不讨论容器的数据结构区别,例如ConcurrentHashMap和ConcurrentLinkedQueue是一类容器,SychronizedMap、SynchronizedList和SynchronizedSet是一类容器。在同一类并发容器中,其同步处理策略基本上是相同的,我们在掌握其中一种容器并法特性后,便可掌握了这一类的并发容器的特性,只需在实际应用中挑选合适的数据结构即可。


二SychronizedMap


SychronizedMap是Collections包提供的一种构造安全Map容器的方法,通过静态方法Collections.synchronizedMap()便可构造一个安全容器。我们通过源码来看一下Collections是如何构造安全容器的,下面是SynchronizedMap的实现代码(JDK8):


private static class SynchronizedMap<K,V>
    implements Map<K,V>, Serializable {
    private final Map<K,V> m;     // Backing Map
    final Object      mutex;        // Object on which to synchronize
    SynchronizedMap(Map<K,V> m) {
        this.m = Objects.requireNonNull(m);
        mutex = this;
    }
    public int size() {
        synchronized (mutex) {return m.size();}
    }
    public boolean isEmpty() {
        synchronized (mutex) {return m.isEmpty();}
    }
    public V get(Object key) {
        synchronized (mutex) {return m.get(key);}
    }
    public V put(K key, V value) {
        synchronized (mutex) {return m.put(key, value);}
    }
    ... \\这里省略
}


我们可以看到SynchronizedMap使用synchronized对Map的所有操作都进行了加锁,从而保证了Map的线程安全性。SynchronizedMap虽然通过加锁保证了Map的线程安全性,但是整个Map只使用了一把独占锁,会造成了同一时间只有一个线程可以获取锁,对Map进行操作。这样Map的并发性就会很差,换句话说SynchronizedMap的并发量其实只有1。为了解决这样的问题,java并发大师Doug Lea开发了性能更好的ConcurrentHashMap类。


三concurrentHashMap


为了避免在多线程环境下竞争一把锁而造成的性能瓶颈问题,ConcurrentHashMap使用了锁分段技术。ConcurrentHashMap将容器中的数据进行了分段(segment),并且每一个段拥有一把锁(ReentrantLock),这样只有多线程在同时访问到同一数据段中的元素(HashEntry)时,才会存在锁竞争问题,这样就大大减少了线程阻塞在同一把锁的概率,从而提高了性能。下图便是ConcurrentHashMap的结构图:


image.png


在JDK 7中Segment类的实现如下:


static class Segment<K,V> extends ReentrantLock implements Serializable {
    ...
}


可以看出Segment继承了ReentrantLock重入锁,可以当作锁来用,因此对于HashEntry的同步操作都依赖于其对应的段的Segment锁。这里需要说明一下,由于HashMap在JDK8中有重大改变,增加了红黑树,其对应的ConcurrentHashMap也不再使用段锁机制来保证容器的线程安全了。在JDK 8中关于Segment添加了这样的说明:


/* Stripped-down version of helper class used in previous version,declared for the sake of serialization compatibility*/


也就是Segment类的声明只为之前版本序列化兼容性操作,虽然JDK8不再使用段锁机制,但是作者认为段锁机制是一种值得我们学习的并发控制思想,在我们的实际开发中,常常不考虑程序并发性能,遇到多线程就上synchronized锁,从头锁到尾,效率非常低下,这样的代码可以说是伪多线程代码,说必定还不如单线程的性能高(毕竟线程切换也是消耗性能的),因此大师级的并发实现必然很值得我们学习。在JDK8中的ConcurrentHashMap是使用了synchronized对Node(树节点)进行加锁操作,这里就不深入进行讨论了,只需读者记住JDK8已经重新实现了ConcurrentHashMap,如果作者以后有机会写HashMap或者红黑树相关的博文时,会深入分析ConcurrentHashMap的实现的。


四CopyOnWriteArrayList


Copy-On-Write写时复制,这又是一种提高系统效率的编程思想。其思想是,在程序正常运行时所有读操作,都基于同一容器进行读操作,在容器进行写操作时,不是通过加锁来控制线程的写锁获取,而是先将容器完全复制出来一份,在新的容器上进行写操作,最后将旧容器的引用指向新容器,这样就完成了新容器的写操作。CopyOnWrite容器与读写锁(ReentrantReadWriteLock)的相同性质,进行了读写区别对待,只在写时加锁,从而提高了容器的性能。CopyOnWriteArrayList.set()实现如下(JDK8):


public E set(int index, E element) {
    final ReentrantLock lock = this.lock;
    lock.lock();
    try {
        Object[] elements = getArray();
        E oldValue = get(elements, index);
        if (oldValue != element) {
            int len = elements.length;
            Object[] newElements = Arrays.copyOf(elements, len);
            newElements[index] = element;
            setArray(newElements);
        } else {
            // Not quite a no-op; ensures volatile write semantics
            setArray(elements);
        }
        return oldValue;
    } finally {
        lock.unlock();
    }
}


从set()方法的实现中,可以发现在更改CopyOnWriteArrayList中的元素时,CopyOnWriteArrayList会将原数组elements进行完全复制,并且更新元素是在新生成的newElements数组的上进行更新,最后再通过setArray()方法将新数组赋值给原数组的引用。而在CopyOnWriteArrayList的读操作中,并没有加锁:


private E get(Object[] a, int index) {
    return (E) a[index];
}


通过上述分析,我们可以总结出CopyOnWrite类容器具有以下性质(优缺点):


  1. 读操作没有加锁,读操作不会存在线程阻塞等待现象。
  2. 写操作会复制整个容器,有可能造成内存大幅增长,使用不当会导致java虚拟机频繁FullGC()。
  3. 读操作不能立即可见。由于写操作是在新数组上进行的,因此新元素不可能对在旧数组上进行读操作的线程可见。


因此,CopyOnWrite在实际开发中,适合在读操作频繁,容器元素稳定的生产环境中使用,并且一定要注意容器大小的控制,频繁的写操作会造成大内存的频繁申请与释放,有可能因此触发java虚拟机的stop-the-world。


本文分析了三种类型的并发容器,在实际使用中如果不是JDK版本的限制,请CucurrentHashMap来替代SychronizedMap。而CopyOnWrite类容器则一般用在容器较为稳定,读操作远比写操作频繁的场景中。


此外说句题外话,我们在学习使用这些并发容器的过程中,不因仅仅学习其用法,更应该通过学习其大师级的设计思想,以及实现方式,来掌握同步控制的技巧,做到触类旁通,举一反三。

相关文章
|
1月前
|
NoSQL 算法 Redis
【Docker】(3)学习Docker中 镜像与容器数据卷、映射关系!手把手带你安装 MySql主从同步 和 Redis三主三从集群!并且进行主从切换与扩容操作,还有分析 哈希分区 等知识点!
Union文件系统(UnionFS)是一种**分层、轻量级并且高性能的文件系统**,它支持对文件系统的修改作为一次提交来一层层的叠加,同时可以将不同目录挂载到同一个虚拟文件系统下(unite several directories into a single virtual filesystem) Union 文件系统是 Docker 镜像的基础。 镜像可以通过分层来进行继承,基于基础镜像(没有父镜像),可以制作各种具体的应用镜像。
347 5
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
348 2
|
8月前
|
机器学习/深度学习 人工智能 JSON
Resume Matcher:增加面试机会!开源AI简历优化工具,一键解析简历和职位描述并优化
Resume Matcher 是一款开源AI简历优化工具,通过解析简历和职位描述,提取关键词并计算文本相似性,帮助求职者优化简历内容,提升通过自动化筛选系统(ATS)的概率,增加面试机会。
1041 18
Resume Matcher:增加面试机会!开源AI简历优化工具,一键解析简历和职位描述并优化
|
8月前
|
网络协议 Shell 网络安全
面试官想听的不仅是命令——如何结构化回答“容器无Shell时如何测试外网”?
“说说看,如果一个Pod的容器没有Shell,如何测试它能否访问外网?”
面试官想听的不仅是命令——如何结构化回答“容器无Shell时如何测试外网”?
|
缓存 前端开发 中间件
[go 面试] 前端请求到后端API的中间件流程解析
[go 面试] 前端请求到后端API的中间件流程解析
|
10月前
|
Java 程序员 开发者
面试官最爱的面试题:wait() 和 notify() 为什么需要同步?
大家好,我是小米。今天来探讨一个常见的Java面试题:为什么线程通信的 `wait()`、`notify()` 和 `notifyAll()` 方法被定义在 Object 类里,且必须在同步方法或同步块中调用?通过小明和小红的工作场景,我们理解了这些方法的核心思想——线程间的协调与通信。它们依赖于对象锁,确保线程按预期顺序执行,避免资源争抢和死锁。掌握这些知识点,能帮助你更好地应对多线程相关的面试问题。如果你对线程同步等话题感兴趣,欢迎继续交流。
160 12
|
11月前
|
Java 程序员
面试官的加分题:super关键字全解析,轻松应对!
小米,29岁程序员,通过一个关于Animal和Dog类的故事,详细解析了Java中super关键字的多种用法,包括调用父类构造方法、访问父类成员变量及调用父类方法,帮助读者更好地理解和应用super,应对面试挑战。
172 3
|
设计模式 Java 关系型数据库
【Java笔记+踩坑汇总】Java基础+JavaWeb+SSM+SpringBoot+SpringCloud+瑞吉外卖/谷粒商城/学成在线+设计模式+面试题汇总+性能调优/架构设计+源码解析
本文是“Java学习路线”专栏的导航文章,目标是为Java初学者和初中高级工程师提供一套完整的Java学习路线。
879 37
|
存储 JSON 网络协议
Docker面试整理-如何查看和管理Docker容器的日志?
通过本文的介绍,我们了解了如何查看和管理Docker容器的日志,包括使用 `docker logs`命令、配置日志驱动、设置日志选项和集中日志管理。掌握这些技能,不仅可以在面试中展示专业水平,也能在实际工作中高效
2141 3
|
存储 网络协议 安全
30 道初级网络工程师面试题,涵盖 OSI 模型、TCP/IP 协议栈、IP 地址、子网掩码、VLAN、STP、DHCP、DNS、防火墙、NAT、VPN 等基础知识和技术,帮助小白们充分准备面试,顺利踏入职场
本文精选了 30 道初级网络工程师面试题,涵盖 OSI 模型、TCP/IP 协议栈、IP 地址、子网掩码、VLAN、STP、DHCP、DNS、防火墙、NAT、VPN 等基础知识和技术,帮助小白们充分准备面试,顺利踏入职场。
1534 2

推荐镜像

更多
  • DNS