Java面试必看：ConcurrentHashMap并发度解析-智慧文博士

文章目录

Java面试必看：ConcurrentHashMap并发度解析？
- 场景还原：面试官与我的对话
- 什么是并发度？
- - 并发度的核心思想
- 并发度的实现细节
- - 1. Segment数组
  - 2. 分段锁机制
  - 3. 动态调整Segment数量
  - 4. 高效的查找机制
- 如何配置合适的并发度？
- - 1. 影响并发度的因素
  - 2. 如何计算合适的并发度
  - 3. 示例代码
- 总结
- 如果你对今天的分享有任何疑问或者想进一步探讨的地方，欢迎随时交流！
- - 📚 领取 | 1000+ 套高质量面试题大合集（无套路，闫工带你飞一把）！

Java面试必看：ConcurrentHashMap并发度解析？

闫工：兄弟们，今天咱们来聊聊Java里的ConcurrentHashMap，这个可是面试中经常被问到的考点之一啊！作为一个有追求的码农，你要是连ConcurrentHashMap的并发度都搞不清楚，那可真是说不过去了。别急，我先不讲那些枯燥的概念，先带大家看看一个真实的面试场景。

场景还原：面试官与我的对话

面试官（面无表情地）：小闫啊，你对ConcurrentHashMap的理解如何？尤其是它的并发度设计。

我（内心紧张，表面装作若无其事）：哦，这个啊，说白了就是它支持高并发读写的那个机制吧？我记得它是基于分段锁实现的，每个Segment里面维护了一个哈希表，这样就能允许多个线程同时操作不同的Segment，对吧？

面试官（眼睛一亮）：嗯，不错。那你说说看，ConcurrentHashMap的并发度具体是怎么体现的？或者说，它是怎么做到高并发的？

我（心里有点小紧张，但还是硬着头皮继续）：这个嘛，我记得它有一个参数叫做concurrencyLevel，也就是我们常说的“并发度”。默认情况下是16，可以通过构造函数来指定。这个值决定了Segment的数量和锁的数量。

面试官（似乎对我的回答感兴趣）：哦？那这个concurrencyLevel具体是怎么影响性能的呢？是不是越大越好？

我（稍微松了口气，开始进入状态）：不完全是这样。虽然较大的concurrencyLevel意味着更多的Segment和更细粒度的锁竞争，但同时也带来了内存消耗增加的问题。所以需要根据实际的应用场景来选择合适的值。

什么是并发度？

简单来说，ConcurrentHashMap的并发度指的是它能够同时处理的最大线程数，或者说是在多线程环境下它能支持的高效操作的数量。这个参数直接影响了ConcurrentHashMap的性能表现，包括读写效率、内存占用等。

并发度的核心思想

ConcurrentHashMap的设计理念可以总结为一句话：通过将整个Map划分为多个Segment（也可以理解为“分段”），每个Segment内部使用同步机制来保证线程安全，从而实现高并发下的高效访问。

具体来说：

分段锁机制：ConcurrentHashMap将数据结构划分为多个Segment，每个Segment都有自己的锁。当一个线程操作某个Segment时，其他线程可以同时操作其他的Segment，这样就减少了锁竞争，提升了并发性能。
动态调整：虽然默认情况下ConcurrentHashMap的Segment数量是固定的（由concurrencyLevel决定），但它会根据实际的情况动态调整Segment的数量，以更好地适应负载变化。
高效的查找机制：除了分段锁之外，ConcurrentHashMap还采用了类似于数组和链表结合的方式存储数据，这样可以在保证线程安全的同时，提供较高的查询效率。

并发度的实现细节

要真正理解ConcurrentHashMap的并发度设计，我们需要从源码层面进行分析。下面我将通过代码片段来解释它的核心实现机制。

1. Segment数组

ConcurrentHashMap的核心数据结构是一个包含多个Segment的数组，每个Segment都维护了一个哈希表（类似于传统的Hashtable）。以下是相关代码：

staticfinalclassSegment<K,V>extendsReentrantLockimplementsSerializable{privatestaticfinallongserialVersionUID=285041397648417399L;// ... 省略其他字段 ...}publicConcurrentMap<K,V>create(){returnnewConcurrentHashMap<>(concurrencyLevel);}publicConcurrentHashMap(intconcurrencyLevel){this.concurrencyLevel=Integer.max(1,concurrencyLevel);// 初始化Segment数组this.segments=newSegment[this.concurrencyLevel];}

从上面的代码可以看出，ConcurrentHashMap通过构造函数初始化了一个长度为concurrencyLevel的Segment数组。每个Segment都对应一个锁，线程在操作时需要先获取对应的锁。

2. 分段锁机制

当线程对某个键进行读写操作时，它会根据该键的哈希值计算出对应的Segment索引，并对该Segment上的锁进行加锁操作。这样做的好处是，即使多个线程同时访问不同的Segment，它们也不会互相阻塞。

publicVget(Objectkey){inthash=hash(key);returnsegmentFor(hash).get(key,hash);}privateSegment<K,V>segmentFor(inthash){// 计算Segment的索引returnsegments[hash&(segments.length-1)];}

3. 动态调整Segment数量

为了应对负载的变化，ConcurrentHashMap会在需要的时候动态地增加Segment的数量。例如，在进行扩容操作时，它会将原有的数据重新分配到更多的Segment中。

privatevoidexpandSegments(inttargetSize){intnewCapacity=segments.length*2;intnewConcurrencyLevel=Integer.min(newCapacity,concurrencyLevel);// 创建新的Segment数组Segment<K,V>[]newSegments=Arrays.copyOf(segments,newConcurrencyLevel);for(inti=segments.length;i<newSegments.length;++i){newSegments[i]=newSegment<>(this);}// 替换旧的Segment数组segments=newSegments;}

4. 高效的查找机制

ConcurrentHashMap中的每个Segment都维护了一个哈希表，通过拉链法来解决哈希冲突。这样不仅保证了线程安全，还提高了查询效率。

staticfinalclassHashEntry<K,V>{finalinthash;finalKkey;volatileVvalue;HashEntry<K,V>next;HashEntry(inth,Kk,Vv){this.hash=h;this.key=k;this.value=v;}}publicVget(Objectkey){inthash=hash(key);if(hash==0)returnnull;// handle special caseHashEntry<K,V>e=entryForNullKey;if(e!=null&&e.hash==hash&&eq(e.key,key)){returne.value;}// 查找对应的Segment并获取值returnsegmentFor(hash).get(key,hash);}

如何配置合适的并发度？

在实际开发中，合理地配置ConcurrentHashMap的并发度非常重要。如果配置不当，可能会导致性能下降或者内存浪费。

1. 影响并发度的因素

线程数量：并发度越高，支持同时操作的线程数越多，但也会占用更多的内存。
负载情况：高负载场景下，需要更大的并发度；低负载场景则可以适当降低。
硬件资源：内存资源充足的环境下，可以考虑设置较高的并发度。

2. 如何计算合适的并发度

一般来说，ConcurrentHashMap的默认值（16）在大多数情况下已经足够。如果你的应用场景中线程数量较多，可以通过以下公式进行估算：

concurrencyLevel = 线程总数 / 3

当然，这只是一个经验值，实际还需要根据测试结果进行调整。

3. 示例代码

publicclassConcurrentHashMapTest{publicstaticvoidmain(String[]args){intconcurrencyLevel=Runtime.getRuntime().availableProcessors()*2;Map<String,String>map=newConcurrentHashMap<>(concurrencyLevel);// 初始化数据...}}