package lock;

import java.util.Map;

import java.util.UUID;

import java.util.concurrent.ConcurrentHashMap;

/**

* @author ： CodeWater

* @create ：2022-06-02-21:28

* @Function Description ：list和set集合线程不安全演示：ConcurrentModificationException并发修改异常

* 解决方案有三种，第一、二种不常用

*/

public class LThreadDemo3 {

public static void main(String[] args ) {

//创建ArrayList集合--------------线程不安全

// List<String> list = new ArrayList<>();

//-----------第一种：vector是线程安全的

// List<String> list = new Vector<>();

//----------第二种：Collections.synchronizedList返回安全的同步列表

// List<String> list = Collections.synchronizedList( new ArrayList<>() );

//---------第三种：CopyOnWriteArrayList(写时复制技术)

// List<String> list = new CopyOnWriteArrayList<>();

// for( int i = 0 ; i < 30 ; i++ ){

// new Thread( () -> {

// //向集合添加内容-----add方法没有synchronized

// list.add( UUID.randomUUID().toString().substring(0 , 8) );

// //从集合获取内容----------并发修改异常发生在这里，因为可能还没放进去就要读取。。。

// System.out.println( list );

// } , String.valueOf( i ) ).start();

// }

//-------------------------------set演示及解决----------------------------

//-------------set.add不安全

// Set<String> set = new HashSet<>();

//------------第一种解决：CopyOnWriteArraySet

// Set<String> set = new CopyOnWriteArraySet<>();

// for( int i = 0 ; i < 30 ; i++ ){

// new Thread( () -> {

// //向集合添加内容-----add方法没有synchronized

// set.add( UUID.randomUUID().toString().substring(0 , 8) );

// //从集合获取内容----------并发修改异常发生在这里，因为可能还没放进去就要读取。。。

// System.out.println( set );

// } , String.valueOf( i ) ).start();

// }

//-------------------------------map演示及解决----------------------------

//hashMap不安全

// Map<String , String> map = new HashMap<>();

//-------------第一种解决：ConcurrentHashMap

Map<String , String> map = new ConcurrentHashMap<>();

for( int i = 0 ; i < 30 ; i++ ){

String key = String.valueOf( i );

new Thread( () -> {

//向集合添加内容-----add方法没有synchronized

map.put( key , UUID.randomUUID().toString().substring(0 , 8) );

//从集合获取内容----------并发修改异常发生在这里，因为可能还没放进去就要读取。。。

System.out.println( map );

} , String.valueOf( i ) ).start();

}

}

}