多线程与高并发-JAVA中写时复制Copy-On-Write-《Java笔记》

admin 2025-10-19 02:22:50 编程 来源:ZONE.CI 全球网 0 阅读模式

Java Copy-On-Write

1、什么是写时复制(Copy-On-Write)容器?

写时复制是指:在并发访问的情景下,当需要修改JAVA中Containers的元素时,不直接修改该容器,而是先复制一份副本,在副本上进行修改。修改完成之后,将指向原来容器的引用指向新的容器(副本容器)。

2、写时复制带来的影响

  • 由于不会修改原始容器,只修改副本容器。因此,可以对原始容器进行并发地读。其次,实现了读操作与写操作的分离,读操作发生在原始容器上,写操作发生在副本容器上。
  • 数据一致性问题:读操作的线程可能不会立即读取到新修改的数据,因为修改操作发生在副本上。但最终修改操作会完成并更新容器,因此这是最终一致性。

    3、写时复制容器的实现

    在JDK中提供了CopyOnWriteArrayList类和CopyOnWriteArraySet类,但是并没有提供CopyOnWriteMap的实现。因此,可以参考CopyOnWriteArrayList自己实现一个CopyOnWriteHashMap主要是在写操作时,如何保证线程安全即可。
    1. import java.util.Collection;
    2. import java.util.HashMap;
    3. import java.util.Map;
    4. import java.util.Set;
    5. public class CopyOnWriteMap<K, V> implements Map<K, V>, Cloneable{
    6. private volatile Map<K, V> internalMap;
    7. public CopyOnWriteMap() {
    8. internalMap = new HashMap<K, V>(100);//初始大小应根据实际应用来指定
    9. }
    10. @Override
    11. public V put(K key, V value) {
    12. synchronized (this) {
    13. Map<K, V> newMap = new HashMap<K, V>(internalMap);//复制出一个新HashMap
    14. V val = newMap.put(key, value);//在新HashMap中执行写操作
    15. internalMap = newMap;//将原来的Map引用指向新Map
    16. return val;
    17. }
    18. }
    19. @Override
    20. public void putAll(Map<? extends K, ? extends V> m) {
    21. synchronized (this) {
    22. Map<K, V> newMap = new HashMap<K, V>(internalMap);
    23. newMap.putAll(m);
    24. internalMap = newMap;
    25. }
    26. }
    27. @Override
    28. public V get(Object key) {
    29. V result = internalMap.get(key);
    30. return result;
    31. }
    32. ......//other methods inherit from interface Map
    33. }
    从上可以看出,对于put()putAll() 而言,需要加锁。而读操作则不需要,如get(Object key)。这样,当一个线程需要put一个新元素时,它先锁住当前CopyOnWriteMap对象,并复制一个新HashMap,而其他的读线程因为不需要加锁,则可继续访问原来的HashMap。这里加锁使用 synchronized 关键字;其实也可以使用 ReentrantLock 对象。官方对synchronized的优化,已经使得synchronized不在一直是重量级;而是满足某种情况才升级为重量级锁。

    4、应用场景

    CopyOnWrite容器适用于读多写少的场景。因为写操作时,需要复制一个容器,造成内存开销很大,也需要根据实际应用把握初始容器的大小。不适合于数据的强一致性场合。若要求数据修改之后立即能被读到,则不能用写时复制技术。因为它是最终一致性。总结:写时复制技术是一种很好的提高并发性的手段。

    5、Copy-On-Write的作用

    集合类(ArrayList、HashMap)上的常用操作是:向集合中添加元素、删除元素、遍历集合中的元素然后进行某种操作。当多个线程并发地对一个集合对象执行这些操作时就会引发ConcurrentModificationException,比如线程A在for-each中遍历ArrayList,而线程B同时又在删除ArrayList中的元素,就可能会抛出ConcurrentModificationException,可以在线程A遍历ArrayList时加锁,但由于遍历操作是一种常见的操作,加锁之后会影响程序的性能,因此for-each遍历选择了不对ArrayList加锁而是当有多个线程修改ArrayList时抛出ConcurrentModificationException,因此,这是一种设计上的权衡。为了应对多线程并发修改这种情况,一种策略就是这里的主题“写时复制”机制;另一种策略是:线程安全的容器类:
    1. ArrayList--->CopyOnWriteArrayList
    2. HashMap--->ConcurrentHashMap
    而ConcurrentHashMap并不是从“复制”这个角度来应对多线程并发修改,而是引入了分段锁(JDK7);CAS、锁(JDK11)解决多线程并发修改的问题。
以太坊cppgolang区别 编程

以太坊cppgolang区别

以太坊是一种去中心化的开源平台,它采用智能合约技术,旨在构建和运行不受干扰的分布式应用程序。作为目前最受欢迎的区块链平台之一,以太坊提供了多种编程语言的支持,其
progolang 编程

progolang

Go语言(Golang)是由Google开发的一门静态类型编程语言。作为一名专业的Golang开发者,我深知这门语言的优势和特点。在本文中,我将介绍Golang
golangn个发送者 编程

golangn个发送者

Golang是一种开源的编程语言,由Google团队开发,旨在提高程序的并发性和简化软件开发过程。在Go语言中,有时需要向多个接收者发送信息。本文将介绍如何在G
golang技能图谱 编程

golang技能图谱

从互联网行业的快速发展到人工智能技术的日益成熟,各种编程语言也应运而生。而在这众多的编程语言中,Golang(即Go)作为一门强大且高效的开发语言备受关注。Go
评论:0   参与:  8