JAVA 并发容器的一些易出错点你知道吗

2024-08-16 00:13:09

并发容器

与同步容器一样，并发容器在总体上也可以分为四大类，分别为：List、Set、Map和Queue。总体上如下图所示。

接下来，我们分别介绍下这些并发容器在使用时的注意事项和避免踩到的坑。

List

并发容器中的List相对来说比较简单，就一个CopyOnWriteArrayList。大家可以从字面的意思中就能够体会到：CopyOnWrite，在写的时候进行复制操作，也就是说在进行写操作时，会将共享变量复制一份。那这样做有什么好处呢？最大的好处就是：读操作可以做到完全无锁化。

在CopyOnWriteArrayList内部维护了一个数组，成员变量array指向这个数组，其核心源代码如下所示。

private transient volatile Object[] array;
final Object[] getArray() {
	return array;
}
final void setArray(Object[] a) {
	array = a;
}

当进行操作时，都是基于array指向的这个内部数组进行的。例如，我们使用Iterator迭代器遍历这个数组时，会按照下图所示的方式进行读操作。

如果在遍历CopyOnWriteArrayList时发生写操作，例如，向数组中增加一个元素时，CopyOnWriteArrayList则会将内部的数组复制一份出来，然后会在新复制出来的数组上添加新的元素，添加完再将array指向新的数组，如下图所示。

对于CopyOnWriteArrayList的其他写操作和添加元素的操作原理相同，这里就不再赘述了。

使用CopyOnWriteArrayList时需要注意的是：

CopyOnWriteArrayList只适合写操作比较少的场景，并且能够容忍读写操作在短时间内的不一致。CopyOnWriteArrayList的迭代器是只读的，不支持写操作。

Set

对于Set接口来说，并发容器中主要有两个实现类，一个是CopyOnWriteArraySet，另一个是ConcurrentSkipListSet。其中，

CopyOnWriteArraySet的使用场景、原理与注意事项和CopyOnWriteArrayList一致。而ConcurrentSkipListSet的使用场景、原理和注意事项和下文的ConcurrentSkipListMap一致。这里，我就不再赘述啦。

Map

在并发容器中，Map接口的实现类主要有ConcurrentHashMap和ConcurrentSkipListMap，而ConcurrentHashMap和ConcurrentSkipListMap最大的区别就是：ConcurrentHashMap的Key是无序的，而ConcurrentSkipListMap的Key是有序的。

在使用ConcurrentHashMap和ConcurrentSkipListMap时，需要注意的是：ConcurrentHashMap和ConcurrentSkipListMap的Key和Value都不能为空。

这里，我们可以将Map相关的类总结成一个表格，如下所示。

Map的实现类	Key是否可为空	Value是否可为空	是否是线程安全的
HashMap	是	是	否
TreeMap	否	是	否
HashTable	否	否	是
ConcurrentHashMap	否	否	是
ConcurrentSkipListMap	否	否	是

这样，大家记忆起来就方便多了。

这里，ConcurrentSkipListMap是基于“跳表”实现的，跳表的插入、删除、查询的平均时间复杂度为O(log n)，这些时间复杂度在理论上与线程数没有关系。如果要追求性能的话，可以尝试使用ConcurrentSkipListMap。

Queue

在Java的并发容器中，Queue相对来说比较复杂。我们先来了解几个概念：

阻塞队列：阻塞一般就是指当队列已满时，入队操作会阻塞；当队列为空时，出队操作就会阻塞。
非阻塞队列：队列的入队和出队操作不会阻塞。
单端队列：队列的入队操作只能在队尾进行，队列的出队操作只能在队首进行。
双端队列：队列的入队操作和出队操作都可以在队首和队尾进行。

我们可以将上述的队列进行组合，将队列分为单端阻塞队列、双端阻塞队列、单端非阻塞队列和双端非阻塞队列。

在Java的并发容器中，会使用明显的标识来区分不同类型的队列。

阻塞队列一个明显的标识就是使用Blocking修饰，例如，ArrayBlockingQueue和LinkedBlockingQueue都是阻塞队列。
单端队列会使用Queue标识，例如ArrayBlockingQueue和LinkedBlockingQueue也是单端队列。
双端队列会使用Deque标识，例如LinkedBlockingDeque和ConcurrentLinkedDeque都是双端队列。

接下来，我们就分别简单聊聊这四种类型的队列。

单端阻塞队列

在Java的并发容器中，单端阻塞队列的主要实现是BlockingQueue，主要包括：ArrayBlockingQueue、LinkedBlockingQueue、SynchronousQueue、LinkedTransferQueue、PriorityBlockingQueue和DelayQueue。

单端阻塞队列的内部一般会有一个队列。

在实现上，内部的队列可以是数组，例如ArrayBlockingQueue，也可以是链表，例如LinkedBlockingQueue。

也可以在内部不存在队列，例如SynchronousQueue，SynchronousQueue实现了生产者的入队操作必须等待消费者的出队操作完成之后才能进行。

LinkedTransferQueue集成了LinkedBlockingQueue和SynchronousQueue的优点，并且性能比LinkedBlockingQueue好。

PriorityBlockingQueue实现了按照优先级进行出队操作，也就是说，队列元素在PriorityBlockingQueue内部可以按照某种规则进行排序。

DelayQueue是延时队列，实现了在一段时间后再出队的操作。

双端阻塞队列

双端阻塞队列的实现主要是LinkedBlockingDeque。示意图如下所示。

单端非阻塞队列

单端非阻塞队列的实现主要是ConcurrentLinkedQueue，示意图如下所示。

双端非阻塞队列

双端非阻塞队列的实现主要是ConcurrentLinkedDeque，示意图如下所示。

有界与无界队列

使用队列时，还要注意队列的有界与无界问题，也就是在使用队列时，需要注意队列是否有容量限制。

在实际工作中，一般推荐使用有界队列。因为无界队列很容易导致内存溢出的问题。在Java的并发容器中，只有ArrayBlockingQueue和LinkedBlockingQueue支持有界，其他的队列都是无界队列。

在使用时，一定要注意内存溢出问题。

总结

今天我们主要介绍了JDK1.5之后提供的并发容器，主要包括：List、Set、Map和Queue，而Queue又可以分为：单端阻塞队列、双端阻塞队列、单端非阻塞队列和双端非阻塞队列。对于每种并发容器，我们简单介绍了其基本原理和注意事项。

本篇文章就到这里了，希望能够给你带来帮助，也希望您能够多多关注我们的更多内容！

Java面试题冲刺第二十五天--并发编程1

目录面试题1:简单说下你对线程和进程的理解? 正经回答: 深入追问: 追问1:那进程和线程有哪些区别呢? 面试题2:守护线程和用户线程的区别? 正经回答: 面试题3:什么是线程死锁? 正经回答: 深入追问: 追问1:形成死锁的四个必要条件是什么? 追问2:我们该如何避免死锁? 追问3:死锁避免和死锁预防有啥不同? 总结面试题1:简单说下你对线程和进程的理解? 正经回答: 进程一个在内存中运行的应用程序.每个进程都有自己独立的一块内存空间,一个进程可以有多个线程,比如在Windows系统中,
Java 高并发的三种实现案例详解

提到锁,大家肯定想到的是sychronized关键字.是用它可以解决一切并发问题,但是,对于系统吞吐量要求更高的话,我们这提供几个小技巧.帮助大家减小锁颗粒度,提高并发能力. 初级技巧-乐观锁乐观锁使用的场景是,读不会冲突,写会冲突.同时读的频率远大于写. 悲观锁的实现: 悲观的认为所有代码执行都会有并发问题,所以将所有代码块都用sychronized锁住乐观锁的实现: 乐观的认为在读的时候不会产生冲突为题,在写时添加锁.所以解决的应用场景是读远大于写时的场景. 中级技巧-String.i
JAVA并发图解

目录总结 JAVA并发总览核心问题并不是程序的漏洞导致的,而是操作系统底层机制导致的原子性: 可见性问题: 改的是缓存,但是缓存对另一个线程不可见有序性问题: 正常应该先创建对象,再赋值:而编译器对指令执行顺序出于某些原因进行了优化,然后改变了执行顺序,如下: 解决方案可见性: 有序性: 这个原则在加了volatile和锁的时候自动生效,也就是说解决了可见性和原子性,可见性顺带就解决了原子性: 操作系统角度,监视器的名字是管程解决了原子性问题,可见性和有序性都能解决并发工具 C
Java面试题冲刺第二十五天--并发编程3

目录面试题1:你了解线程池么?简单介绍一下. 追问1:连接池和线程池是一个意思么?有什么区别? 不同点面试题2:线程池中核心线程数量大小你是怎么设置的? 追问1:核心线程数量过大或过小会造成什么后果? 面试题3:线程池都有哪些状态呀? 追问1:什么条件下会进入TERMINATED状态总结面试题1:你了解线程池么?简单介绍一下. java提供的一个java.util.concurrent.Executor接口的实现用于创建线程池. 线程池是一种多线程处理形式,处理过程中将任务提交到线程
Java面试题冲刺第二十四天--并发编程

目录面试题1:说一下你对ReentrantLock的理解? CAS: AQS: 追问1:你认为 ReentrantLock 相比 synchronized 都有哪些区别? 面试题2:解释一下公平锁和非公平锁? 面试题3:能详细说一下CAS具体实现原理么? 追问1:那CAS的缺陷有哪些呢? 1.ABA: 2.自旋消耗资源: 3.多变量共享一致性问题: 追问2:讲一下什么是ABA问题?怎么解决? 总结面试题1:说一下你对ReentrantLock的理解? ReentrantLock是JDK1.5
轻轻松松吃透Java并发fork/join框架

目录一.概述二.说一说 RecursiveTask 三. Fork/Join框架基本使用四.工作顺序图 1.ForkJoinPool构造函数 2.fork方法和join方法五.使用Fork/Join解决实际问题 1.使用归并算法解决排序问题 2.使用Fork/Join运行归并算法 Fork / Join 是一个工具框架 , 其核心思想在于将一个大运算切成多个小份 , 最大效率的利用资源 , 其主要涉及到三个类 : ForkJoinPool / ForkJoinTask / Recursi
JAVA 并发容器的一些易出错点你知道吗

目录并发容器 List Set Map Queue 单端阻塞队列双端阻塞队列单端非阻塞队列双端非阻塞队列有界与无界队列总结并发容器与同步容器一样,并发容器在总体上也可以分为四大类,分别为:List.Set.Map和Queue.总体上如下图所示. 接下来,我们分别介绍下这些并发容器在使用时的注意事项和避免踩到的坑. List 并发容器中的List相对来说比较简单,就一个CopyOnWriteArrayList.大家可以从字面的意思中就能够体会到:CopyOnWrite,在写的时候进
基于Java并发容器ConcurrentHashMap#put方法解析

jdk1.7.0_79 HashMap可以说是每个Java程序员用的最多的数据结构之一了,无处不见它的身影.关于HashMap,通常也能说出它不是线程安全的.这篇文章要提到的是在多线程并发环境下的HashMap--ConcurrentHashMap,显然它必然是线程安全的,同样我们不可避免的要讨论散列表,以及它是如何实现线程安全的,它的效率又是怎样的,因为对于映射容器还有一个Hashtable也是线程安全的但它似乎只出现在笔试.面试题里,在现实编码中它已经基本被遗弃. 关于HashMap的线程不
Java并发容器相关知识总结

一.并发容器 1.1 JDK 提供的并发容器总结 JDK 提供的这些容器大部分在java.util.concurrent包中. ConcurrentHashMap: 线程安全的 HashMap CopyOnWriteArrayList: 线程安全的 List,在读多写少的场合性能非常好,远远好于 Vector. ConcurrentLinkedQueue: 高效的并发队列,使用链表实现.可以看做一个线程安全的 LinkedList,这是一个非阻塞队列. BlockingQueue: 这是一个接口
Java并发容器介绍

目录 1.原子类 2.锁 3.并发容器 4.List接口下 5.Map接口下 6.Set接口下 7.Queue接口下 Java并发包(concurrent)是Java用来处理并发问题的利器,该并发包中主要有原子类,锁(lock),并发容器类等等.本系列博客主要就是介绍并发包中一些常用的并发容器,常用的类.那么就让我们一起来揭开并发包的面纱吧. 环境: 基于JDK1.8 1.原子类首先登场的就是我们的原子类.啥是原子类?原子类用啥用? 第一个问题,啥是原子类:操作具有原子性的类,我们称之为原子类
java并发容器ConcurrentHashMap深入分析

目录前言基础回顾红黑树红黑树数据结构红黑树插入数据多线程竞争下的读写操作扩容原理正在扩容 && 有多个线程正在竞争扩容期间的读操作扩容期间的写操作总结前言我是fancy,一个年纪轻轻bug量就累计到3200个的程序员,同事们都夸我一个人养活了整个测试组. 最近迷上了并发编程.并发这玩意怎么说呢,就是你平时工作用不到,一用就用在面试上.这不,又卷起了并发容器. 那说起并发容器,你一定也知道那几个,CopyOnWriteArrayList.并发队列BlockingQu
java并发容器CopyOnWriteArrayList实现原理及源码分析

CopyOnWriteArrayList是Java并发包中提供的一个并发容器,它是个线程安全且读操作无锁的ArrayList,写操作则通过创建底层数组的新副本来实现,是一种读写分离的并发策略,我们也可以称这种容器为"写时复制器",Java并发包中类似的容器还有CopyOnWriteSet.本文会对CopyOnWriteArrayList的实现原理及源码进行分析. 实现原理我们都知道,集合框架中的ArrayList是非线程安全的,Vector虽是线程安全的,但由于简单粗暴的锁同步机制,
Java同步容器和并发容器详解

同步容器在 Java 中,同步容器主要包括 2 类: Vector.Stack.HashTableCollections 类中提供的静态工厂方法创建的类(由 Collections.synchronizedXxxx 等方法) Collections类中提供的静态工厂方法创建的类 Vector 实现了 List 接口,Vector 实际上就是一个数组,和 ArrayList 类似,但是Vector 中的方法都是 synchronized 方法,即进行了同步措施. Stack 也是一个同步容器,它
Java多线程编程中的两种常用并发容器讲解

ConcurrentHashMap并发容器 ConcurrentHashMap可以做到读取数据不加锁,并且其内部的结构可以让其在进行写操作的时候能够将锁的粒度保持地尽量地小,不用对整个ConcurrentHashMap加锁. ConcurrentHashMap的内部结构 ConcurrentHashMap为了提高本身的并发能力,在内部采用了一个叫做Segment的结构,一个Segment其实就是一个类Hash Table的结构,Segment内部维护了一个链表数组,我们用下面这一幅图来看下Con
Java从同步容器到并发容器的操作过程

引言容器是Java基础类库中使用频率最高的一部分,Java集合包中提供了大量的容器类来帮组我们简化开发,我前面的文章中对Java集合包中的关键容器进行过一个系列的分析,但这些集合类都是非线程安全的,即在多线程的环境下,都需要其他额外的手段来保证数据的正确性,最简单的就是通过synchronized关键字将所有使用到非线程安全的容器代码全部同步执行.这种方式虽然可以达到线程安全的目的,但存在几个明显的问题:首先编码上存在一定的复杂性,相关的代码段都需要添加锁.其次这种一刀切的做法在高并发情况下性
Java并发CopyOnWrite容器原理解析

这篇文章主要介绍了Java并发CopyOnWrite容器原理解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 Copy-On-Write简称COW,是一种用于程序设计中的优化策略.其基本思路是,从一开始大家都在共享同一个内容,当某个人想要修改这个内容的时候,才会真正把内容Copy出去形成一个新的内容然后再改,这是一种延时懒惰策略.从JDK1.5开始Java并发包里提供了两个使用CopyOnWrite机制实现的并发容器,它们是CopyOnWri