ConcurrentMap.putIfAbsent(key,value)用法实例
本文研究的主要是ConcurrentMap.putIfAbsent(key,value)用法的相关内容，具体如下。
业务上经常会遇到有这种场景，全局维护一个并发的ConcurrentMap, Map的每个Key对应一个对象，这个对象需要只创建一次。如果Map中该key对应的value不存在则创建，否则直接返回。
我们先看一下代码：
public static Locale getInstance(String language, String country,
String variant) {
//...
String key = some_string;
Locale locale = map.get(key);
if (locale == null) {
locale = new Locale(language, country, variant);
map.put(key, locale);
}
return locale;
}
这段代码要做的事情是：
- 调用 map.get(key) 方法，判断 map 里面是否有该 key 对应的 value （Locale 对象）。
- 如果返回 null，表示 map 里面没有要查找的 key-value mapping。new 一个 Locale 对象，并把 new 出来的这个对象与 key 一起放入 map。
- 最后返回新创建的 Locale 对象
我们期望每次调用 getInstance 方法时要保证相同的 key 返回同一个 Local 对象引用。这段代码能实现这个需求吗？
答案是：在单线程环境下可以满足要求，但是在多线程环境下会存在线程安全性问题，即不能保证在并发的情况相同的 key 返回同一个 Local 对象引用。
这是因为在上面的代码里存在一个习惯被称为 put-if-absent 的操作 [1]，而这个操作存在一个 race condition：
if (locale == null) {
locale = new Locale(language, country, variant);
map.put(key, locale);
}
因为在某个线程做完 locale == null 的判断到真正向 map 里面 put 值这段时间，其他线程可能已经往 map 做了 put 操作，这样再做 put 操作时，同一个 key 对应的 locale 对象被覆盖掉，最终 getInstance 方法返回的同一个 key 的 locale 引用就会出现不一致的情形。所以对 Map 的 put-if-absent 操作是不安全的（thread safty）。
为了解决这个问题，java 5.0 引入了 ConcurrentMap 接口，在这个接口里面 put-if-absent 操作以原子性方法 putIfAbsent(K key, V value) 的形式存在。正如 javadoc 写的那样：
putIfAbsent方法主要是在向ConcurrentHashMap中添加键—值对的时候，它会先判断该键值对是否已经存在。
- 如果不存在（新的entry），那么会向map中添加该键值对，并返回null。
- 如果已经存在，那么不会覆盖已有的值，直接返回已经存在的值。
对上面方法进行改造：
public static Locale getInstance(String language, String country,
String variant) {
//...
String key = some_string;
Locale locale = map.get(key);
if (locale == null) {
locale = new Locale(language, country, variant);
map.putIfAbsent(key, locale);
}
return locale;
}
这段代码使用了 Map 的 concurrent 形式（ConcurrentMap、ConcurrentHashMap），并简单的使用了语句map.putIfAbsent(key, locale) 。这同样不能保证相同的 key 返回同一个 Locale 对象引用。
这里的错误出在忽视了 putIfAbsent 方法是有返回值的，并且返回值很重要。
所以，使用 putIfAbsent 方法时切记要对返回值进行判断。
public static Locale getInstance(String language, String country,
String variant) {
//...
String key = some_string;
Locale locale = map.get(key);
if (locale == null) {
locale = new Locale(language, country, variant);
Locale tmp = map.putIfAbsent(key, locale);
if (tmp != null) {
locale = tmp;
}
}
return locale;
}
【实例1】
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
public class Test {
public static void main(String[] args) {
//测试一下currentHashMap.putIfAbsent()
Map<long, String> clientMap = new ConcurrentHashMap<>();
System.out.println("首先打印空的clientMap");
System.out.println("clientMap: " + clientMap);
System.out.println();
//在空的clientMap中添加一个新的记录
System.out.println("在空的clientMap中添加一个新的记录");
System.out.println("添加之前的clientMap: " + clientMap);
long netId = 1234567L;
String str1 = "michael";
String result = clientMap.putIfAbsent(netId, str1);
System.out.println("添加之后的clientMap: " + clientMap);
System.out.println("查看返回值result: " + result);
System.out.println();
//重复添加
System.out.println("重复添加上一次的记录");
System.out.println("添加之前的clientMap: " + clientMap);
String result2 = clientMap.putIfAbsent(netId, str1);
System.out.println("添加之后的clientMap: " + clientMap);
System.out.println("查看返回值result: " + result2);
System.out.println();
}
}
总结
以上就是本文关于ConcurrentMap.putIfAbsent(key,value)用法实例的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！
相关文章
GC（Garbage Collection）称之为垃圾回收，是对内存中的垃圾对象,采用一定的算法进行内存回收的一个动作，这篇文章主要介绍了JVM中的GC初识,需要的朋友可以参考下2022-05-05
这篇文章主要介绍了springBoot接入阿里云oss的实现步骤，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-01-01
springboot yml配置文件定义list集合、数组和map以及使用中的错误
这篇文章主要介绍了springboot yml配置文件定义list集合、数组和map以及使用中遇到的错误问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-07-07
这篇文章主要介绍了Spring Boot Admin 的使用详解，Spring Boot Admin 用于监控基于 Spring Boot 的应用，有兴趣的可以了解一下2017-09-09
Mybatis属于半自动ORM，在使用这个框架中，工作量最大的就是书写Mapping的映射文件，由于手动书写很容易出错，我们可以利用Mybatis-Generator来帮我们自动生成文件。本文主要给大家介绍mybatis逆向工程自动生成代码，感兴趣的朋友一起学习吧2016-04-04
PowerJob的TimingStrategyHandler工作流程源码解读
这篇文章主要为大家介绍了PowerJob的TimingStrategyHandler工作流程源码解读,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2024-01-01
这篇文章主要介绍了Mybatis Plus查询时sql字段名大小写报错的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-12-12
Spring Boot 的诞生是为了简化Spring程序的开发，今天给大家介绍下Spring Boot 的创建和运行，主要包括Spring Boot基本概念和springboot优点，本文通过实例代码给大家介绍的非常详细，需要的朋友参考下吧2022-07-07
这篇文章主要介绍了解决Idea启动Spring Boot很慢的问题,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2018-12-12
今天小编就为大家分享一篇使用jsoup解析html的table中的文本信息实例，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-05-05
最新评论