JDK 1.8 之 Map.merge()
2019-10-12 08:23:57来源:博客园 阅读 ()
JDK 1.8 之 Map.merge()
Map
中ConcurrentHashMap
是线程安全的,但不是所有操作都是,例如get()
之后再put()
就不是了,这时使用merge()
确保没有更新会丢失。
因为Map.merge()
意味着我们可以原子地执行插入或更新操作,它是线程安全的。
一、源码解析
default V merge(K key, V value, BiFunction<? super V, ? super V, ? extends V> remappingFunction) {
Objects.requireNonNull(remappingFunction);
Objects.requireNonNull(value);
V oldValue = get(key);
V newValue = (oldValue == null) ? value :
remappingFunction.apply(oldValue, value);
if(newValue == null) {
remove(key);
} else {
put(key, newValue);
}
return newValue;
}
该方法接收三个参数,一个 key
值,一个 value
,一个 remappingFunction
。如果给定的key
不存在,它就变成了put(key, value)
;但是,如果key
已经存在一些值,我们 remappingFunction
可以选择合并的方式:
- 只返回新值即可覆盖旧值:
(old, new) -> new
; - 只需返回旧值即可保留旧值:
(old, new) -> old
; - 合并两者,例如:
(old, new) -> old + new
; - 删除旧值:
(old, new) -> null
。
二、使用场景
merge()
方法在统计时用的场景比较多,例如:有一个学生成绩对象的列表,对象包含学生姓名、科目、科目分数三个属性,求得每个学生的总成绩。
2.1 准备数据
- 学生对象
StudentEntity.java
@Data
public class StudentEntity {
/**
* 学生姓名
*/
private String studentName;
/**
* 学科
*/
private String subject;
/**
* 分数
*/
private Integer score;
}
- 学生成绩数据
private List<StudentEntity> buildATestList() {
List<StudentEntity> studentEntityList = new ArrayList<>();
StudentEntity studentEntity1 = new StudentEntity() {{
setStudentName("张三");
setSubject("语文");
setScore(60);
}};
StudentEntity studentEntity2 = new StudentEntity() {{
setStudentName("张三");
setSubject("数学");
setScore(70);
}};
StudentEntity studentEntity3 = new StudentEntity() {{
setStudentName("张三");
setSubject("英语");
setScore(80);
}};
StudentEntity studentEntity4 = new StudentEntity() {{
setStudentName("李四");
setSubject("语文");
setScore(85);
}};
StudentEntity studentEntity5 = new StudentEntity() {{
setStudentName("李四");
setSubject("数学");
setScore(75);
}};
StudentEntity studentEntity6 = new StudentEntity() {{
setStudentName("李四");
setSubject("英语");
setScore(65);
}};
StudentEntity studentEntity7 = new StudentEntity() {{
setStudentName("王五");
setSubject("语文");
setScore(80);
}};
StudentEntity studentEntity8 = new StudentEntity() {{
setStudentName("王五");
setSubject("数学");
setScore(85);
}};
StudentEntity studentEntity9 = new StudentEntity() {{
setStudentName("王五");
setSubject("英语");
setScore(90);
}};
studentEntityList.add(studentEntity1);
studentEntityList.add(studentEntity2);
studentEntityList.add(studentEntity3);
studentEntityList.add(studentEntity4);
studentEntityList.add(studentEntity5);
studentEntityList.add(studentEntity6);
studentEntityList.add(studentEntity7);
studentEntityList.add(studentEntity8);
studentEntityList.add(studentEntity9);
return studentEntityList;
}
2.2 一般方案
思路:用Map
的一组key/value
存储一个学生的总成绩(学生姓名作为key
,总成绩为value
)
Map
中不存在指定的key
时,将传入的value
设置为key
的值;- 当
key
存在值时,取出存在的值与当前值相加,然后放入Map
中。
public void normalMethod() {
Long startTime = System.currentTimeMillis();
// 造一个学生成绩列表
List<StudentEntity> studentEntityList = buildATestList();
Map<String, Integer> studentScore = new HashMap<>();
studentEntityList.forEach(studentEntity -> {
if (studentScore.containsKey(studentEntity.getStudentName())) {
studentScore.put(studentEntity.getStudentName(),
studentScore.get(studentEntity.getStudentName()) + studentEntity.getScore());
} else {
studentScore.put(studentEntity.getStudentName(), studentEntity.getScore());
}
});
log.info("各个学生成绩:{},耗时:{}ms",studentScore, System.currentTimeMillis() - startTime);
}
2.3 Map.merge()
很明显,这里需要采用
remappingFunction
的合并方式。
public void mergeMethod() {
Long startTime = System.currentTimeMillis();
// 造一个学生成绩列表
List<StudentEntity> studentEntityList = buildATestList();
Map<String, Integer> studentScore = new HashMap<>();
studentEntityList.forEach(studentEntity -> studentScore.merge(
studentEntity.getStudentName(),
studentEntity.getScore(),
Integer::sum));
log.info("各个学生成绩:{},耗时:{}ms",studentScore, System.currentTimeMillis() - startTime);
}
2.4 测试及小结
- 测试方法
@Test
public void testAll() {
// 一般写法
normalMethod();
// merge()方法
mergeMethod();
}
- 测试结果
00:21:28.305 [main] INFO cn.van.jdk.eight.map.merge.MapOfMergeTest - 各个学生成绩:{李四=225, 张三=210, 王五=255},耗时:75ms
00:21:28.310 [main] INFO cn.van.jdk.eight.map.merge.MapOfMergeTest - 各个学生成绩:{李四=225, 张三=210, 王五=255},耗时:2ms
- 结果小结
merger()
方法使用起来在一定程度上减少了代码量,使得代码更加简洁。同时,通过打印的方法耗时可以看出,merge()
方法效率更高。Map.merge()
的出现,和ConcurrentHashMap
的结合,完美处理那些自动执行插入或者更新操作的单线程安全的逻辑.
三、总结
3.1 示例源码
Github 示例代码
3.2 技术交流
- 风尘博客
- 风尘博客-CSDN
- 风尘博客-掘金
原文链接:https://www.cnblogs.com/vandusty/p/11644487.html
如有疑问请与原作者联系
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
- jdk各个版本下载 2020-06-11
- HashMap1.7和1.8,红黑树原理! 2020-06-03
- JDK8的JVM内存模型小结 2020-06-03
- JDK1.7和1.8的HashMap对比详解 2020-06-02
- 当IntelliJ IDEA2020.1遇上JDK14:所有美好环环相扣 2020-06-01
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash