Java Concurrency 简明教程
Java Concurrency - ConcurrentMap Interface
java.util.concurrent.ConcurrentMap 接口是 Map 接口的子接口,支持对基础映射变量执行原子操作。它具有类似于易失变量上的读写操作的 get 和 set 方法。也就是说,某项设置与对同一变量执行的任何后续 get 操作之间存在发生在前关系。此接口确保线程安全和原子性保证。
ConcurrentMap Methods
Sr.No. |
Method & Description |
1 |
default V compute(K key, BiFunction<? super K,? super V,? extends V> remappingFunction) 尝试计算指定键及其当前映射值的映射(如果没有当前映射,则为 null)。 |
2 |
default V computeIfAbsent(K key, Function<? super K,? extends V> mappingFunction) 如果指定的键尚未与某个值关联(或已映射至 null),则尝试使用给定的映射函数计算它的值,并且如果该值为非 null,则将它输入到此映射。 |
3 |
default V computeIfPresent(K key, BiFunction<? super K,? super V,? extends V> remappingFunction) 如果针对指定键的值已存在且为非 null,则尝试在提供键及其当前映射值的情况下计算一个新映射。 |
4 |
default void forEach(BiConsumer<? super K,? super V> action) 对该映射中的每个条目执行给定的操作,直到处理完所有条目或该操作引发异常。 |
5 |
default V getOrDefault(Object key, V defaultValue) 返回指定键映射到的值,如果此映射不包含用于该键的映射,则返回 defaultvalue。 |
6 |
default V merge(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction) 如果指定的键尚未与某个值关联或已与 null 关联,则使用指定的非 null 值与该键进行关联。 |
7 |
V putIfAbsent(K key, V value) 如果指定的键尚未与某个值关联,则使用给定的值与该键进行关联。 |
8 |
boolean remove(Object key, Object value) 仅在当前映射到给定值的情况下,才移除针对某个键的条目。 |
9 |
V replace(K key, V value) 仅在当前映射到某个值的情况下,才替换针对某个键的条目。 |
10 |
boolean replace(K key, V oldValue, V newValue) 仅在当前映射到给定值的情况下,才替换针对某个键的条目。 |
11 |
default void replaceAll(BiFunction<? super K,? super V,? extends V> function) 用在每个条目上调用给定函数的结果替换每个条目的值,直到处理完所有条目或该函数引发异常。 |
Example
以下 TestThread 程序展示了 ConcurrentMap 与 HasMap 的用法。
import java.util.ConcurrentModificationException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class TestThread {
public static void main(final String[] arguments) {
Map<String,String> map = new ConcurrentHashMap<String, String>();
map.put("1", "One");
map.put("2", "Two");
map.put("3", "Three");
map.put("5", "Five");
map.put("6", "Six");
System.out.println("Initial ConcurrentHashMap: " + map);
Iterator<String> iterator = map.keySet().iterator();
try {
while(iterator.hasNext()) {
String key = iterator.next();
if(key.equals("3")) {
map.put("4", "Four");
}
}
} catch(ConcurrentModificationException cme) {
cme.printStackTrace();
}
System.out.println("ConcurrentHashMap after modification: " + map);
map = new HashMap<String, String>();
map.put("1", "One");
map.put("2", "Two");
map.put("3", "Three");
map.put("5", "Five");
map.put("6", "Six");
System.out.println("Initial HashMap: " + map);
iterator = map.keySet().iterator();
try {
while(iterator.hasNext()) {
String key = iterator.next();
if(key.equals("3")) {
map.put("4", "Four");
}
}
System.out.println("HashMap after modification: " + map);
} catch(ConcurrentModificationException cme) {
cme.printStackTrace();
}
}
}
这将产生以下结果。
Output
Initial ConcurrentHashMap: {1 = One, 2 = Two, 3 = Three, 5 = Five, 6 = Six}
ConcurrentHashMap after modification: {1 = One, 2 = Two, 3 = Three, 4 = Four, 5 = Five, 6 = Six}
Initial HashMap: {1 = One, 2 = Two, 3 = Three, 5 = Five, 6 = Six}
java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextNode(Unknown Source)
at java.util.HashMap$KeyIterator.next(Unknown Source)
at TestThread.main(TestThread.java:48)