第七章:同步类容器,vector 线程安全与hashmap线程不安全等的举例

第七章:同步类容器,vector 线程安全与hashmap线程不安全等的举例第七章:同步类容器,vector 线程安全与hashmap线程不安全等的举例

大家好,又见面了,我是你们的朋友全栈君。

转自:https://blog.csdn.net/u012453843/article/details/73744277

  同步类容器,常见的有Vectorr和HashTable,也就是我们常说的线程安全的两个集合容器,这些容器的同步功能其实都是由JDK的Collections.synchronized***等工厂方法去创建的。其底层的机制无非就是用传的synchronized关键字对每个共用的方法都进行同步,使得每次只能有一个线程访问容器的状态。这很明显不满足我们今天互联网时代高并发的需求,在保证线程安全的同时,也必须要有足够好的性能。

        同步类容器虽然是线程安全的,但是在某些场景下可能需要加锁来保护复合操作。复合类操作如:迭代(反复访问元素,遍历完容器中所有的元素)、跳转(根据指定的顺序找到当前元素的下一个元素)、以及条件运算。这些复合操作在多线程并发地修改容器时,可能会表现出意外的行为,最经典的便是ConcurrentModificationException,原因是当容器迭代的过程中,被并发的修改了内容,这是由于早期迭代器设计的时候并没有考虑并发修改的问题。

        上面都是些干巴巴的理论,下面我们来看一个例子,这个例子就是同步容器出现异常的情况。我们在迭代容器中的元素的时候是不能增加或减少元素的,否则就会报ConcurrentModificationException异常。这跟我们遍历ArrayList的时候删除或增加元素报异常是一样的。

package com.xiaoyexinxin.ThreadLearn;

import java.util.Iterator;  
import java.util.Vector;  
  
/**  
 * 同步类容器  
 *  
 */  
public class SynContainer {  
    //初始化火车票池并添加火车票:为避免线程安全问题,可采用Vector替代ArrayList,HashTable替代HashMap  
    public static void main(String[] args){  
        final Vector<String> tickets = new Vector<>();  
        //向tickets中添加票  
        for(int i=0;i<=100;i++){  
            tickets.add("火车票"+i);  
        }  
        //遍历tickets,并在遍历的过程当中删除一个元素  
        for (Iterator iterator = tickets.iterator(); iterator.hasNext();) {  
            String element = (String) iterator.next();  
            tickets.remove(10);//删除掉索引号为10的元素  
        }  
    }  
}

结果:

Exception in thread "main" java.util.ConcurrentModificationException
	at java.util.Vector$Itr.checkForComodification(Unknown Source)
	at java.util.Vector$Itr.next(Unknown Source)
	at com.xiaoyexinxin.ThreadLearn.SynContainer.main(SynContainer.java:20)

之所以说Vector是线程安全的,我们看一下add方法便知道了,如下图所示,可以看到,上来便在add方法上加上了synchronized锁,同一时间只能有一个线程进行写操作,当然线程安全了,但是随之而来的便是效率太过低下。

另外遍历过程中不能使用remove删除元素;这种方式的问题在于,删除某个元素后,list的大小发生了变化,而你的索引也在变化,所以会导致你在遍历的时候漏掉某些元素。比如当你删除第1个元素后,继续根据索引访问第2个元素时,因为删除的关系后面的元素都往前移动了一位,所以实际访问的是第3个元素。因此,这种方式可以用在删除特定的一个元素时使用,但不适合循环删除多个元素时使用.

第七章:同步类容器,vector 线程安全与hashmap线程不安全等的举例

同理remove也是有synchronized同步锁的。

   我们知道,HashMap不是线程安全的,那么我们怎么验证HashMap不是线程安全的呢?我们举个例子,如下图所示。

package com.xiaoyexinxin.ThreadLearn;

import java.util.Collections;  
import java.util.HashMap;  
import java.util.Map;  
  
public class SynContainer2 {  
     
    public static void main(String[] args){  
       //Map<String,String> map = Collections.synchronizedMap(new HashMap<String,String>());  
        final Map<String,String> map = new HashMap<String,String>();  
       Thread t1 = new Thread(new Runnable() {  
          
            public void run() {  
                for(int i=0;i<25;i++){  
                    map.put(String.valueOf(i), String.valueOf(i));  
                }  
            }  
        },"t1");  
         
        Thread t2 = new Thread(new Runnable() {  
              
            @Override  
            public void run() {  
                for(int j=25;j<50;j++){  
                    map.put(String.valueOf(j), String.valueOf(j));  
                }  
            }  
        },"t2");  
        t1.start();  
        t2.start();  
        try {  
            Thread.sleep(1000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        } 
        System.out.println("@@@");
        for(int k=0;k<50;k++){  
//            if(!String.valueOf(k).equals(map.get(String.valueOf(k)))){  
                System.out.println(String.valueOf(k)+":"+map.get(String.valueOf(k)));  
//            }  
        }  
    }  

}

结果:

@@@
0:0
1:1
2:2
3:3
4:4
5:5
6:6
7:7
8:8
9:9
10:null
11:null
12:12
13:null
14:null
15:15
16:16
17:17
18:18
19:19
20:20
21:21
22:22
23:23
24:24
25:null
26:26
27:27
28:28
29:29
30:30
31:31
32:32
33:33
34:34
35:35
36:36
37:37
38:38
39:39
40:40
41:41
42:42
43:43
44:44
45:45
46:46
47:47
48:48
49:49

运行上面的方法,有时会看到如下图所示的结果,我们明明向map中添加的都是整数转成的字符串,现在却出现了这种数据,说明HashMap不是线程安全的。

 我们再把HashMap经过Collections.synchronizedMap进行处理(把注释掉的那行代码放开,如下图所示)。

再多执行几次main方法,发现没有任何异常数据输出,这说明经过Collections.synchronizedMap(new HashMap<String,String>());这样处理的HashMap已经变成线程安全的了。不过,由于它加了锁,因此并发效率自然而然就低了。

package com.xiaoyexinxin.ThreadLearn;

import java.util.Collections;  
import java.util.HashMap;  
import java.util.Map;  
  
public class SynContainer2 {  
     
    public static void main(String[] args){  
       final Map<String,String> map = Collections.synchronizedMap(new HashMap<String,String>());  
//        final Map<String,String> map = new HashMap<String,String>();  
       Thread t1 = new Thread(new Runnable() {  
          
            public void run() {  
                for(int i=0;i<25;i++){  
                    map.put(String.valueOf(i), String.valueOf(i));  
                }  
            }  
        },"t1");  
         
        Thread t2 = new Thread(new Runnable() {  
              
            @Override  
            public void run() {  
                for(int j=25;j<50;j++){  
                    map.put(String.valueOf(j), String.valueOf(j));  
                }  
            }  
        },"t2");  
        t1.start();  
        t2.start();  
        try {  
            Thread.sleep(1000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        } 
        System.out.println("@@@");
        for(int k=0;k<50;k++){  
//            if(!String.valueOf(k).equals(map.get(String.valueOf(k)))){  
                System.out.println(String.valueOf(k)+":"+map.get(String.valueOf(k)));  
//            }  
        }  
    }  

}

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/106145.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • linux c++进程间通信_c++多线程通信

    linux c++进程间通信_c++多线程通信Linux下c开发之——线程间通信2016-02-1817:50

  • FindWindow函数

    FindWindow函数FindWindow函数用来查询主窗口(子窗口不能查询),并且返回窗口句柄。函数原型:praram[in]lpClassName:以NULL结尾的字符串,如果为NULL,则查找所有与lpWindow

  • python dll注入 网络_dll注入

    python dll注入 网络_dll注入一、什么是dll​动态链接库(DynamicLinkLibrary或者Dynamic-linkLibrary,缩写为DLL)​是微软公司在微软Windows操作系统中,实现共享函数库概念的一种方式。​这些库函数的扩展名是”.dll”、”.ocx”(包含ActiveX控制的库)或者”.drv”(旧式的系统驱动程序)。pip3install二、为何要有dll​…

  • C语言read函数

    C语言read函数从文件中读取指定大小的字节函数read()语法:ssize_tread(intfd,void*buf,intcount)说明:read函数从指定的打开的文件fd中读取指定大小count的字节到从buf开始的缓冲区中.返回值:若读取失败则返回-1.读取成功则返回实际读取到的字节数,有两种情况:…

  • MySQL里有2000w数据,redis中只存20w的数据,如何保证redis中的数据都是热点数据?「建议收藏」

    MySQL里有2000w数据,redis中只存20w的数据,如何保证redis中的数据都是热点数据?

  • decltype 使用

    decltype 使用功能decltype可以将给定的表达式或变量的类型推导出来,包含引用和指针。一般用于复杂表达式作为返回值的类型推导。可以用于补足c++11的auto缺陷.编译阶段的事情,不会任何执行,表达式也不会执行。类型规则规则一:声明类型,类型包含引用就有引用,没有引用也不会自行添加。规则二:返回值则根据返回值类型确定最终类型。规则三:表达式根据默认和重载得到的最终类型。不建议特别复杂的表达式。声明类型分析案例一intmain()..

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号