Java 8 - juc - ConcurrentHashMap

川长思鸟来 2023-10-11 22:41 24阅读 0赞

import java.util.concurrent.ConcurrentHashMap;
    
    /**
     * ConcurrentHashMap进行并发的读和写操作：
     * <p>
     * 创建一个ConcurrentHashMap实例，用于存储键值对。
     * 使用put方法向ConcurrentHashMap中添加键值对。
     * 创建多个线程执行读操作，通过get方法读取指定键的值。
     * 创建一个线程执行写操作，使用put方法添加新的键值对。
     * 执行读操作和写操作的线程并发执行，ConcurrentHashMap保证了线程安全的并发访问。
     */
    public class MyConcurrentHashMapExample {
        
    
        public static void main(String[] args) {
        
            // 创建一个ConcurrentHashMap实例
            ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<>();
    
            // 向ConcurrentHashMap中添加键值对
            map.put("A", 1);
            map.put("B", 2);
            map.put("C", 3);
    
            // 执行并发的读操作
            Runnable readTask = () -> {
        
                String threadName = Thread.currentThread().getName();
                System.out.println(threadName + " - Read Operation: " + map.get("A"));
            };
    
            // 执行并发的写操作
            Runnable writeTask = () -> {
        
                String threadName = Thread.currentThread().getName();
                map.put("D", 4);
                System.out.println(threadName + " - Write Operation: " + map.get("D"));
            };
    
            // 创建多个线程进行读操作
            for (int i = 0; i < 3; i++) {
        
                new Thread(readTask).start();
            }
    
            // 创建一个线程进行写操作
            new Thread(writeTask).start();
        }
    }