共计 4396 个字符，预计需要花费 11 分钟才能阅读完成。
摘要：ConcurrentHashMap ConcurrentHashMap 底层具体实现 JDK 1.7 底层实现 将数据分为一段一段的存储，然后给每一段数据配一把锁，当一个线程占用锁访问其中一个段数据时，其他段的数据也能被其他线程访问。
ConcurrentHashMap
ConcurrentHashMap 底层具体实现
JDK 1.7 底层实现
将数据分为一段一段的存储，然后给每一段数据配一把锁，当一个线程占用锁访问其中一个段数据时，其他段的数据也能被其他线程访问。
ConcurrentHashMap 是由 Segment 数组结构和 HashEntry 数组结构组成。其中 Segment 实现了 ReentrantLock, 所以 Segment 是一种可重入锁，扮演锁的角色。HashEntry 用于存储键值对数据。
一个 ConcurrentHashMap 里包含一个 Segment 数组。Segment 结构和 HashMap 类似，是一种数组和链表结构，一个 Segment 包含一个 HashEntry 数组，每个 HashEntry 是一个链表结构的元素，每个 Segment 守护着一个 HashEntry 数组里的元素，当对 HashEntry 数组的数据进行修改时，必须首先获得对应的 Segment 的锁。
JDK 1.8 底层实现
TreeBin: 红黑二叉树节点 Node: 链表节点
v2-9e5e57b2227df02dc231978862ff5cf8_b.png
ConcurrentHashMap 取消了 Segment 分段锁，采用 CAS 和 synchronized 来保证并发安全。数据结构与 HashMap1.8 的结构类似，数组 + 链表 / 红黑二叉树(链表长度 >8 时，转换为红黑树)。
synchronized 只锁定当前链表或红黑二叉树的首节点，这样只要 hash 值不冲突，就不会产生并发。
ConcurrentHashMap 和 Hashtable 的区别
底层数据结构：
JDK1.7 的 ConcurrentHashMap 底层采用分段的数组 + 链表实现，JDK1.8 的 ConcurrentHashMap 底层采用的数据结构与 JDK1.8 的 HashMap 的结构一样，数组 + 链表 / 红黑二叉树。
Hashtable 和 JDK1.8 之前的 HashMap 的底层数据结构类似都是采用数组 + 链表的形式，数组是 HashMap 的主体，链表则是主要为了解决哈希冲突而存在的
实现线程安全的方式
JDK1.7 的 ConcurrentHashMap（分段锁）对整个桶数组进行了分割分段(Segment)，每一把锁只锁容器其中一部分数据，多线程访问容器里不同数据段的数据，就不会存在锁竞争，提高并发访问率。JDK 1.8 采用数组 + 链表 / 红黑二叉树的数据结构来实现，并发控制使用 synchronized 和 CAS 来操作。
Hashtable: 使用 synchronized 来保证线程安全，效率非常低下。当一个线程访问同步方法时，其他线程也访问同步方法，可能会进入阻塞或轮询状态，如使用 put 添加元素，另一个线程不能使用 put 添加元素，也不能使用 get，竞争会越来越激烈。
HashTable 全表锁
v2-72e2203eeb5a463c4a0fd6295ce6fc8a_b.png
ConcurrentHashMap 分段锁
v2-658c1f06db5fe9820c8c15e151462e7a_b.png
CopyOnWriteArrayList
public class CopyOnWriteArrayList extends Object
implements List, RandomAccess, Cloneable, Serializable
在很多应用场景中，读操作可能会远远大于写操作。由于读操作根本不会修改原有的数据，因此对于每次读取都进行加锁其实是一种资源浪费。我们应该允许多个线程同时访问 List 的内部数据，毕竟读取操作是安全的。这和 ReentrantReadWriteLock 读写锁的思想非常类似，也就是读读共享、写写互斥、读写互斥、写读互斥。JDK 中提供了 CopyOnWriteArrayList 类比相比于在读写锁的思想又更进一步。为了将读取的性能发挥到极致，CopyOnWriteArrayList 读取是完全不用加锁的，并且写入也不会阻塞读取操作。只有写入和写入之间需要进行同步等待。这样，读操作的性能就会大幅度提高。
CopyOnWriteArrayList 的实现机制
CopyOnWriteArrayLis 类的所有可变操作（add，set 等等）都是通过创建底层数组的新副本来实现的。当 List 需要被修改的时候，我并不修改原有内容，而是对原有数据进行一次复制，将修改的内容写入副本。写完之后，再将修改完的副本替换原来的数据，这样就可以保证写操作不会影响读操作了。
CopyOnWriteArrayList 是满足 CopyOnWrite 的 ArrayList，所谓 CopyOnWrite 也就是说：在计算机，如果你想要对一块内存进行修改时，我们不在原有内存块中进行写操作，而是将内存拷贝一份，在新的内存中进行写操作，写完之后呢，就将指向原来内存指针指向新的内存，原来的内存就可以被回收掉了。
CopyOnWriteArrayList 读取和写入源码简单分析
CopyOnWriteArrayList 读取操作的实现
读取操作没有任何同步控制和锁操作，因为内部数组 array 不会发生修改，只会被另外一个 array 替换，因此可以保证数据安全。
/* The array, accessed only via getArray/setArray. /
private transient volatile Object[] array;
public E get(int index) {
[Java] 纯文本查看 复制代码
?
1
return get(getArray(), index);
}
@SuppressWarnings(“unchecked”)
private E get(Object[] a, int index) {
[Java] 纯文本查看 复制代码
?
1
return (E) a[index];
}
final Object[] getArray() {
[Java] 纯文本查看 复制代码
?
1
return array;
}
CopyOnWriteArrayList 读取操作的实现
CopyOnWriteArrayList 写入操作 add() 方法在添加集合的时候加了锁，保证同步，避免了多线程写的时候会复制出多个副本出来。
/**
Appends the specified element to the end of this list.
*/
public boolean add(E e) {
[Java] 纯文本查看 复制代码
?
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();// 释放锁}
}
ConcurrentLinkedQueue
Java 提供的线程安全的 Queue 可以分为阻塞队列和非阻塞队列，其中阻塞队列的典型例子是 BlockingQueue，非阻塞队列的典型例子是 ConcurrentLinkedQueue，在实际应用中要根据实际需要选用阻塞队列或者非阻塞队列。阻塞队列可以通过加锁来实现，非阻塞队列可以通过 CAS 操作实现。
ConcurrentLinkedQueue 使用链表作为其数据结构。ConcurrentLinkedQueue 应该算是在高并发环境中性能最好的队列了。它之所有能有很好的性能，是因为其内部复杂的实现。
ConcurrentLinkedQueue 主要使用 CAS 非阻塞算法来实现线程安全。适合在对性能要求相对较高，对个线程同时对队列进行读写的场景，即如果对队列加锁的成本较高则适合使用无锁的 ConcurrentLinkedQueue 来替代。
BlockingQueue
java.util.concurrent.BlockingQueue 接口有以下阻塞队列的实现：
FIFO 队列：LinkedBlockingQueue、ArrayBlockingQueue（固定长度）
优先级队列：PriorityBlockingQueue
提供了阻塞的 take() 和 put() 方法：如果队列为空 take() 将阻塞，直到队列中有内容；如果队列为满 put() 将阻塞，直到队列有空闲位置。
使用 BlockingQueue 实现生产者消费者问题
public class ProducerConsumer {
[Java] 纯文本查看 复制代码
?
private static BlockingQueue<String> queue = new ArrayBlockingQueue<>(5);
private static class Producer extends Thread {
@Override
public void run() {
try {queue.put("product");
} catch (InterruptedException e) {e.printStackTrace();
}
System.out.print("produce..");
}}
private static class Consumer extends Thread {
@Override
public void run() {
try {String product = queue.take();
} catch (InterruptedException e) {e.printStackTrace();
}
System.out.print("consume..");
}}
}
public static void main(String[] args) {
[Java] 纯文本查看 复制代码
?
for (int i = 0; i < 2; i++) {
Producer producer = new Producer();
producer.start();}
for (int i = 0; i < 5; i++) {
Consumer consumer = new Consumer();
consumer.start();}
for (int i = 0; i < 3; i++) {
Producer producer = new Producer();
producer.start();}
}
produce..produce..consume..consume..produce..consume..produce..consume..produce..consume