jdk1.8 ConcurrentHashMap怎么扩容?
时间: 2024-01-06 10:25:19 浏览: 100
JDK1.8 ConcurrentHashMap的一点理解
5星 · 资源好评率100%
ConcurrentHashMap在JDK 1.8中的扩容机制如下:
1. 当某个线程进行put操作时,如果发现ConcurrentHashMap正在进行扩容,则该线程会与扩容线程一起进行扩容操作。
2. 如果某个线程put操作时,发现ConcurrentHashMap没有正在进行扩容,则将key-value添加到ConcurrentHashMap中,然后判断是否超过了阈值。如果超过了阈值,则进行扩容。
3. 扩容之前,先生成一个新的数组,新数组的大小是原数组的两倍。
4. 在转移元素时,首先将原数组分组,然后将每组分配给不同的线程来进行元素的转移。每个线程负责一组或多组的转移工作。
5. 在转移元素的过程中,使用CAS操作来保证线程安全。
下面是一个示例代码,演示了ConcurrentHashMap的扩容过程:
```java
import java.util.concurrent.ConcurrentHashMap;
public class ConcurrentHashMapDemo {
public static void main(String[] args) {
ConcurrentHashMap<Integer, String> map = new ConcurrentHashMap<>();
// 添加元素到ConcurrentHashMap
for (int i = 0; i < 10; i++) {
map.put(i, "value" + i);
}
// 输出当前ConcurrentHashMap的容量
System.out.println("Current capacity: " + map.size());
// 进行扩容
map.put(10, "value10");
// 输出扩容后的容量
System.out.println("New capacity: " + map.size());
}
}
```
运行以上代码,可以看到输出结果为:
```
Current capacity: 10
New capacity: 11
```
阅读全文