大数据必学Java基础(六十二):ConcurrentMap并发容器对比

举报
Lansonli 发表于 2022/10/01 00:21:35 2022/10/01
【摘要】 ​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

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。