大数据必学Java基础(六十二):ConcurrentMap并发容器对比
【摘要】 ConcurrentMap并发容器对比JDK5.0之后提供了多种并发类容器可以替代同步类容器,提升性能、吞吐量ConcurrentHashMap替代HashMap、HashTableConcurrentSkipListMap替代TreeMap简单原理:并发情况下,验证提高性能一、ConcunrrentHashMappublic class Test { //这是main方法,程序的入...
ConcurrentMap并发容器对比
JDK5.0之后提供了多种并发类容器可以替代同步类容器,提升性能、吞吐量
ConcurrentHashMap替代HashMap、HashTable
ConcurrentSkipListMap替代TreeMap
简单原理:
并发情况下,验证提高性能
一、ConcunrrentHashMap
public class Test {
//这是main方法,程序的入口
public static void main(String[] args) {
//选择一个容器:
ConcurrentHashMap<String,Integer> map = new ConcurrentHashMap<>();
//创建10个线程:
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
long startTime = System.currentTimeMillis();
for (int j = 0; j < 1000000; j++) {
map.put("test" + j , j);
}
long endTime = System.currentTimeMillis();
System.out.println("一共需要的时间:" + (endTime - startTime));
}
}).start();
}
}
}
结果:
二、Hashtable
package com.lanson.test03;
import java.util.Hashtable;
import java.util.concurrent.ConcurrentHashMap;
/**
* @author : lanson
*/
public class Test {
//这是main方法,程序的入口
public static void main(String[] args) {
//选择一个容器:
//ConcurrentHashMap<String,Integer> map = new ConcurrentHashMap<>();
Hashtable map = new Hashtable();
//创建10个线程:
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
long startTime = System.currentTimeMillis();
for (int j = 0; j < 1000000; j++) {
map.put("test" + j , j);
}
long endTime = System.currentTimeMillis();
System.out.println("一共需要的时间:" + (endTime - startTime));
}
}).start();
}
}
}
结果:
三、HashMap
package com.lanson.test03;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.concurrent.ConcurrentHashMap;
/**
* @author : lanson
*/
public class Test {
//这是main方法,程序的入口
public static void main(String[] args) {
//选择一个容器:
//ConcurrentHashMap<String,Integer> map = new ConcurrentHashMap<>();
//Hashtable map = new Hashtable();
HashMap map = new HashMap();
//创建10个线程:
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
long startTime = System.currentTimeMillis();
for (int j = 0; j < 1000000; j++) {
map.put("test" + j , j);
}
long endTime = System.currentTimeMillis();
System.out.println("一共需要的时间:" + (endTime - startTime));
}
}).start();
}
}
}
结果:
四、线程安全的HashMap
package com.lanson.test03;
import java.util.Collections;
import java.util.HashMap;
import java.util.Hashtable;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
/**
* @author : lanson
*/
public class Test {
//这是main方法,程序的入口
public static void main(String[] args) {
//选择一个容器:
//ConcurrentHashMap<String,Integer> map = new ConcurrentHashMap<>();
//Hashtable map = new Hashtable();
HashMap oldmap = new HashMap();
Map map = Collections.synchronizedMap(oldmap);
//创建10个线程:
for (int i = 0; i < 10; i++) {
new Thread(new Runnable() {
@Override
public void run() {
long startTime = System.currentTimeMillis();
for (int j = 0; j < 1000000; j++) {
map.put("test" + j , j);
}
long endTime = System.currentTimeMillis();
System.out.println("一共需要的时间:" + (endTime - startTime));
}
}).start();
}
}
}
结果:
五、总结
ConcurrentHashMap:性能高,线程安全
Hashtable: 线程安全,性能低
HashMap:线程不安全,性能高
线程安全的HashMap:线程安全,性能低
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱:
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论(0)