首页 技术 正文
技术 2022年11月23日
0 收藏 704 点赞 4,809 浏览 1945 个字
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;public class ConcurrentHashMapDemo1 { private static Map<Long, Integer> widgetCacheMap = new ConcurrentHashMap<Long, Integer>(); /**
* @param args
*/
public static void main(String[] args) {
for (int i = ; i < ; i++) {
Thread tt = new Thread(new Rund());
tt.start();
}
} static class Rund implements Runnable { public void run() {
test();
} /**
* 1W次,总有那么几次线程不安全
*/
public void test() {
synchronized ("") {// 解决方案
ConcurrentHashMapDemo1 tt = new ConcurrentHashMapDemo1();
tt.set();
int s1 = widgetCacheMap.get(1L).intValue();
tt.change();
int s2 = widgetCacheMap.get(1L).intValue();
if (s1 == s2) {
System.out.println(s1 + ":" + s2);
}
}
} } public void set() {
Map<Long, Integer> mm = new HashMap<Long, Integer>();
mm.put(1L, );
widgetCacheMap = mm;
} public void change() {
Map<Long, Integer> mm = new HashMap<Long, Integer>();
mm.put(1L, );
widgetCacheMap = mm;
}}
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;public class ConcurrentHashMapDemo2 { public static void main(String[] args) throws InterruptedException {
for (int i = ; i < ; i++) {
System.out.println(test());
}
} private static int test() throws InterruptedException {
ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<String, Integer>();
ExecutorService pool = Executors.newCachedThreadPool();
for (int i = ; i < ; i++) {
pool.execute(new MyTask(map));
}
pool.shutdown();
pool.awaitTermination(, TimeUnit.DAYS); return map.get(MyTask.KEY);
}
}class MyTask implements Runnable { public static Object lock = new Object(); public static final String KEY = "key"; private ConcurrentHashMap<String, Integer> map; public MyTask(ConcurrentHashMap<String, Integer> map) {
this.map = map;
} @Override
public void run() {
for (int i = ; i < ; i++) {
synchronized (lock) { // 解决方案
this.addup();
}
}
} private void addup() {
if (!map.containsKey(KEY)) {
map.put(KEY, );
} else {
map.put(KEY, map.get(KEY) + );
}
}
}

总结:ConcurrentHashMap是线程安全的,那是在他们的内部操作,其外部操作还是需要自己来保证其同步的,特别是静态的ConcurrentHashMap,其有更新和查询的过程,要保证其线程安全,需要syn一个不可变的参数才能保证其原子性

微信扫一扫

支付宝扫一扫

本文网址:https://www.zhankr.net/140769.html

相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:875 阅读:5,090
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:806 阅读:3,508
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:565 阅读:4,320
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:730 阅读:4,314
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:4,920
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:3,105
发表评论
暂无评论

还没有评论呢,快来抢沙发~

助力内容变现

将您的收入提升到一个新的水平

点击联系客服

在线时间:8:00-16:00

客服电话

400-888-8888

客服邮箱

ceotheme@ceo.com

扫描二维码

关注微信公众号

扫描二维码

手机访问本站