栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

集合类在高并发下的实战

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

集合类在高并发下的实战

集合类在高并发下的实战

List 不安全
出现场景 : 多线程环境下访问ArrayList
bug类型 :
java.util.concurrent.CopyOnWriteArrayList–并发修改异常

  • 解决方案
    • new Vector()
    • List arrayList = Collections.synchronizedList(new ArrayList<>())
    • CopyonWriteArrayList arrayList1 = new CopyOnWriteArrayList<>()
package com.sydstart.unsafe;

import java.util.*;
import java.util.concurrent.CopyOnWriteArrayList;


public class ListTest {
    public static void main(String[] args) {
//        java.util.ConcurrentModificationException 并发修改异常
        List arrayList = Collections.synchronizedList(new ArrayList<>());
        CopyOnWriteArrayList arrayList1 = new CopyOnWriteArrayList<>();
//        并发下是不安全的
        
        for (int i = 1; i <=10 ; i++) {
            new Thread(()->{
                arrayList.add(UUID.randomUUID().toString().substring(0,5));
                System.out.println(arrayList);
            },String.valueOf(i)).start();
        }
    }
}
 

Set

  • 总结:
    解决方案
    1.Set set = Collections.synchronizedSet(new HashSet());
    2.CopyonWriteArraySet set01 = new CopyOnWriteArraySet<>();
package com.sydstart.unsafe;


import java.util.*;
import java.util.concurrent.CopyOnWriteArraySet;


public class SetTest {
    public static void main(String[] args) {
        Set set = Collections.synchronizedSet(new HashSet());
        CopyOnWriteArraySet set00 = new CopyOnWriteArraySet<>();
        for (int i = 1; i <= 10; i++) {
            new Thread(()-> {
                set.add(UUID.randomUUID().toString().substring(0,5));
                System.out.println(set);
                
            },String.valueOf(i)).start();
        }
    }
}
 

HashMap不安全

package com.sydstart.unsafe;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Hashtable;
import java.util.UUID;
import java.util.concurrent.ConcurrentHashMap;


public class MapTest {
    public static void main(String[] args) {
        ConcurrentHashMap hashMap= new ConcurrentHashMap<>();
        Hashtable ht = new Hashtable<>();
//        方案一 : Collections.synchronizedMap(hashMap);
//        方案二 :方案二 :Hashtable hashTable= new Hashtable();
        for (int i = 0; i < 10; i++) {
            new Thread(()->{
                int i1  =0;
                ht.put(i1++ , UUID.randomUUID().toString().substring(0,5));
                System.out.println(ht);
            },"A").start();
        }
        for (int i = 0; i < 10; i++) {
            new Thread(()->{
                int i1  =0;
                ht.put(i1++ , UUID.randomUUID().toString().substring(0,5));
                System.out.println(ht);
            },"B").start();

        }

    }
}
转载请注明:文章转载自 www.mshxw.com
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号