Java Concurrency - อินเทอร์เฟซ ConcurrentMap

อินเทอร์เฟซ java.util.concurrent.ConcurrentMap เป็นอินเทอร์เฟซย่อยของอินเทอร์เฟซแผนที่รองรับการทำงานของอะตอมบนตัวแปรแผนที่ที่อยู่เบื้องหลัง มันมีวิธีการรับและตั้งค่าที่ทำงานเหมือนอ่านและเขียนบนตัวแปรระเหย นั่นคือชุดมีความสัมพันธ์ที่เกิดขึ้นก่อนกับการรับตัวแปรเดียวกันในภายหลัง อินเทอร์เฟซนี้ช่วยให้มั่นใจได้ถึงความปลอดภัยของเธรดและการรับประกันอะตอม

วิธีการแผนที่พร้อมกัน

ซีเนียร์	วิธีการและคำอธิบาย
1	default V compute(K key, BiFunction<? super K,? super V,? extends V> remappingFunction) พยายามคำนวณการแมปสำหรับคีย์ที่ระบุและค่าที่แมปปัจจุบัน (หรือค่าว่างหากไม่มีการแมปปัจจุบัน)
2	default V computeIfAbsent(K key, Function<? super K,? extends V> mappingFunction) หากคีย์ที่ระบุไม่ได้เชื่อมโยงกับค่า (หรือแมปกับค่าว่าง) ให้พยายามคำนวณค่าโดยใช้ฟังก์ชันการแม็ปที่กำหนดและป้อนลงในแผนที่นี้เว้นแต่เป็นค่าว่าง
3	default V computeIfPresent(K key, BiFunction<? super K,? super V,? extends V> remappingFunction) หากค่าของคีย์ที่ระบุเป็นปัจจุบันและไม่ใช่ค่าว่างให้พยายามคำนวณการแมปใหม่ที่ให้คีย์และค่าที่แม็ปปัจจุบัน
4	default void forEach(BiConsumer<? super K,? super V> action) ดำเนินการตามที่กำหนดสำหรับแต่ละรายการในแผนที่นี้จนกว่ารายการทั้งหมดจะได้รับการประมวลผลหรือการดำเนินการทำให้เกิดข้อยกเว้น
5	default V getOrDefault(Object key, V defaultValue) ส่งกลับค่าที่คีย์ที่ระบุถูกแมปหรือ defaultValue หากแมปนี้ไม่มีการแมปสำหรับคีย์
6	default V merge(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction) หากคีย์ที่ระบุไม่ได้เชื่อมโยงกับค่าหรือเชื่อมโยงกับ null ให้เชื่อมโยงกับค่าที่ไม่ใช่ค่าว่างที่กำหนด
7	V putIfAbsent(K key, V value) หากคีย์ที่ระบุไม่ได้เชื่อมโยงกับค่าให้เชื่อมโยงกับค่าที่กำหนด
8	boolean remove(Object key, Object value) ลบรายการสำหรับคีย์เฉพาะในขณะที่แมปกับค่าที่กำหนด
9	V replace(K key, V value) แทนที่รายการสำหรับคีย์เฉพาะในขณะที่แมปกับค่าบางค่า
10	boolean replace(K key, V oldValue, V newValue) แทนที่รายการสำหรับคีย์เฉพาะในขณะที่แมปกับค่าที่กำหนด
11	default void replaceAll(BiFunction<? super K,? super V,? extends V> function) แทนที่ค่าของแต่ละรายการด้วยผลลัพธ์ของการเรียกใช้ฟังก์ชันที่กำหนดในรายการนั้นจนกว่ารายการทั้งหมดจะได้รับการประมวลผลหรือฟังก์ชันจะแสดงข้อยกเว้น

ตัวอย่าง

โปรแกรม TestThread ต่อไปนี้แสดงการใช้ ConcurrentMap เทียบกับ HashMap

import java.util.ConcurrentModificationException;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class TestThread {

   public static void main(final String[] arguments) {
      Map<String,String> map = new ConcurrentHashMap<String, String>();

      map.put("1", "One");
      map.put("2", "Two");
      map.put("3", "Three");
      map.put("5", "Five");
      map.put("6", "Six");

      System.out.println("Initial ConcurrentHashMap: " + map);
      Iterator<String> iterator = map.keySet().iterator();

      try { 
         
         while(iterator.hasNext()) {
            String key = iterator.next();
            
            if(key.equals("3")) {
               map.put("4", "Four");
            }
         }
      } catch(ConcurrentModificationException cme) {
         cme.printStackTrace();
      }
      System.out.println("ConcurrentHashMap after modification: " + map);

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

      map.put("1", "One");
      map.put("2", "Two");
      map.put("3", "Three");
      map.put("5", "Five");
      map.put("6", "Six");

      System.out.println("Initial HashMap: " + map);
      iterator = map.keySet().iterator();

      try {
         
         while(iterator.hasNext()) {
            String key = iterator.next();
            
            if(key.equals("3")) {
               map.put("4", "Four");
            }
         }
         System.out.println("HashMap after modification: " + map);
      } catch(ConcurrentModificationException cme) {
         cme.printStackTrace();
      }
   }  
}

สิ่งนี้จะให้ผลลัพธ์ดังต่อไปนี้

เอาต์พุต

Initial ConcurrentHashMap: {1 = One, 2 = Two, 3 = Three, 5 = Five, 6 = Six}
ConcurrentHashMap after modification: {1 = One, 2 = Two, 3 = Three, 4 = Four, 5 = Five, 6 = Six}
Initial HashMap: {1 = One, 2 = Two, 3 = Three, 5 = Five, 6 = Six}
java.util.ConcurrentModificationException
	at java.util.HashMap$HashIterator.nextNode(Unknown Source)
	at java.util.HashMap$KeyIterator.next(Unknown Source)
	at TestThread.main(TestThread.java:48)