CopyOnWriteArrayList:深入理解Java中的线程安全List原理和应用

简介: CopyOnWriteArrayList:深入理解Java中的线程安全List原理和应用

1️⃣ 什么是CopyOnWrite(写时复制)

CopyOnWrite,也被称为写时复制(Copy-On-Write,简称COW),是程序设计领域中的一种优化策略。这种策略的核心思想是,当多个调用者(或线程)同时访问同一份资源时,他们会共同获取一个指向该资源的指针。只要没有调用者尝试修改这份资源,所有的调用者都可以继续访问同一个资源。但是,一旦有调用者尝试修改资源,系统就会复制一份该资源的副本给这个调用者,而其他调用者所见到的仍然是原来的资源。这个过程对其他的调用者都是透明的,他们并不知道资源已经被复制。


在Java中,CopyOnWriteArrayList和CopyOnWriteArraySet就是使用了这种策略的两个类。这两个类都位于java.util.concurrent包下,是线程安全的集合类。当需要修改集合中的元素时,它们不会直接在原集合上进行修改,而是复制一份新的集合,然后在新的集合上进行修改。修改完成后,再将指向原集合的引用指向新的集合。这种设计使得读操作可以在不加锁的情况下进行,从而提高了并发性能。


总的来说,CopyOnWrite是一种适用于读多写少场景的优化策略,它通过复制数据的方式实现了读写分离,提高了并发性能。但是,它也存在一些潜在的性能问题,如内存占用增加、写操作性能下降以及频繁的垃圾回收。因此,在使用时需要根据具体场景进行权衡和选择。


2️⃣什么是CopyOnWriteArrayList

CopyOnWriteArrayList是Java并发包java.util.concurrent中的一个类,它实现了List接口。如其名所示,


CopyOnWriteArrayList是Java中的一个类,位于java.util.concurrent包下。它是ArrayList的一个线程安全的变体,其中所有可变操作(如add和set等)都是通过创建底层数组的新副本来实现的,因此被称为“写时复制”的列表。


由于CopyOnWriteArrayList在遍历时不会对列表进行任何修改,因此它绝对不会抛出ConcurrentModificationException的异常。它在修改操作(如add、set等)时,会复制一份底层数组,然后在新的数组上进行修改,修改完成后再将指向底层数组的引用切换到新的数组。这种设计使得读操作可以在不加锁的情况下进行,从而提高了并发性能,这个特性使得它在多线程环境下进行遍历操作时更为安全。


然而,CopyOnWriteArrayList并没有“扩容”的概念。每次写操作(如add或remove)都需要复制一个全新的数组,这在写操作较为频繁时可能会导致性能问题,因为复制整个数组的操作是相当耗时的。因此,在使用CopyOnWriteArrayList时,需要特别注意其适用场景,一般来说,它更适合于读多写少的场景。


3️⃣CopyOnWriteArrayList的工作原理

CopyOnWriteArrayList是ArrayList的一个线程安全的变体。读操作可以在不加锁的情况下进行,从而提高了并发性能。


具体来说,CopyOnWriteArrayList内部有一个可重入锁(ReentrantLock)来保证线程安全,但这个锁只在写操作时才会被使用。当进行修改操作时,线程会先获取锁,然后复制底层数组,并在新数组上执行修改。修改完成后,通过volatile关键字修饰的引用来确保新的数组对所有线程可见。由于读操作不需要获取锁,因此多个线程可以同时进行读操作,而不会相互干扰。

3.1 读写分离的设计模式的几个优点

  • 读操作性能很高

由于读操作不需要获取锁,因此多个线程可以同时进行读操作,而不会相互干扰。这使得在高并发场景下,CopyOnWriteArrayList的读操作性能非常出色。

  • 数据一致性

由于写操作是通过复制底层数组并在新数组上执行修改来实现的,因此不会出现多个线程同时修改同一个元素的情况。这保证了数据的一致性。

  • 适用于读多写少的场景

由于写操作需要复制整个底层数组,因此在写操作较为频繁的场景下,CopyOnWriteArrayList的性能可能会受到较大影响。但在读多写少的场景下,它可以充分发挥其优势。

3.2 存在的性能问题

  • 内存占用

每次写操作都需要复制整个底层数组,这会导致内存占用增加。特别是在列表较大时,这种内存开销可能会变得非常显著。

  • 写操作性能下降

由于每次写操作都需要复制整个数组,并在新数组上执行修改,因此写操作的性能可能会受到较大影响。特别是在高并发场景下,这种性能下降可能会更加明显。

  • 频繁的垃圾回收

由于写操作会创建新的数组,因此可能导致频繁的垃圾回收。这可能会对系统的整体性能产生影响。

总的来说,CopyOnWriteArrayList是一种适用于读多写少场景的线程安全列表实现。它通过复制底层数组的方式实现了读写分离,提高了读操作的并发性能。但在使用时需要根据具体场景进行权衡和选择,以避免潜在的性能问题。


3️⃣CopyOnWriteArrayList使用场景

CopyOnWriteArrayList适用于读多写少的场景。在这种场景下,由于读操作不需要获取锁,因此可以充分发挥多核CPU的并行计算能力,提高系统的吞吐量。然而,在写操作较为频繁的场景下,CopyOnWriteArrayList的性能可能会受到较大影响。


4️⃣CopyOnWriteArrayList的应用

下面是一个使用CopyOnWriteArrayList的代码,它模拟了一个简单的新闻发布系统。在这个系统中,多个线程可以并发地添加新闻和读取新闻列表。由于读操作远多于写操作,因此使用CopyOnWriteArrayList是合适的。

import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

// 新闻类
class News {
    private String title;
    private String content;

    public News(String title, String content) {
        this.title = title;
        this.content = content;
    }

    public String getTitle() {
        return title;
    }

    public String getContent() {
        return content;
    }

    @Override
    public String toString() {
        return "News{" +
                "title='" + title + '\'' +
                ", content='" + content + '\'' +
                '}';
    }
}

// 新闻发布系统类
public class NewsPublisherSystem {
    // 使用CopyOnWriteArrayList存储新闻列表
    private final List<News> newsList = new CopyOnWriteArrayList<>();

    // 添加新闻
    public void addNews(News news) {
        newsList.add(news);
        System.out.println("新闻已添加: " + news);
    }

    // 获取新闻列表
    public List<News> getNewsList() {
        return newsList;
    }

    // 模拟多线程添加和读取新闻
    public void simulate() {
        ExecutorService executor = Executors.newFixedThreadPool(10);

        // 提交5个添加新闻的任务
        for (int i = 0; i < 5; i++) {
            final int index = i;
            executor.submit(() -> {
                for (int j = 0; j < 10; j++) {
                    News news = new News("新闻标题" + index + "-" + j, "新闻内容" + index + "-" + j);
                    addNews(news);
                    try {
                        // 模拟新闻发布的延迟
                        TimeUnit.MILLISECONDS.sleep(50);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }

        // 提交5个读取新闻列表的任务
        for (int i = 0; i < 5; i++) {
            executor.submit(() -> {
                for (int j = 0; j < 20; j++) {
                    System.out.println("当前新闻列表: " + getNewsList());
                    try {
                        // 模拟读取新闻列表的延迟
                        TimeUnit.MILLISECONDS.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            });
        }

        // 关闭执行器服务
        executor.shutdown();
        try {
            if (!executor.awaitTermination(1, TimeUnit.MINUTES)) {
                executor.shutdownNow();
            }
        } catch (InterruptedException e) {
            executor.shutdownNow();
            Thread.currentThread().interrupt();
        }
    }

    public static void main(String[] args) {
        NewsPublisherSystem system = new NewsPublisherSystem();
        system.simulate();
    }
}

NewsPublisherSystem类维护了一个CopyOnWriteArrayList来存储新闻对象。addNews方法用于添加新闻到列表中,而getNewsList方法用于获取当前的新闻列表。


在simulate方法中,我们创建了一个固定大小的线程池,并提交了10个任务:其中5个任务用于添加新闻,另外5个任务用于读取新闻列表。每个添加新闻的任务会创建并添加10条新闻,而每个读取新闻列表的任务会读取新闻列表20次。


由于使用了CopyOnWriteArrayList,多个线程可以同时读取新闻列表,而不会有线程安全问题。当添加新闻时,CopyOnWriteArrayList会复制底层数组,从而保证读取操作不会受到写操作的影响。


请注意,由于CopyOnWriteArrayList在写操作时会复制整个底层数组,因此在新闻列表非常大且写操作频繁的情况下,性能可能会受到影响。在这种情况下,可能需要考虑其他并发数据结构或同步策略。然而,在本案例中,由于读操作远多于写操作,使用CopyOnWriteArrayList是合适的。

5️⃣总结

CopyOnWriteArrayList是Java并发编程中一个重要的线程安全列表实现。它通过复制底层数组的方式实现了读写分离,提高了读操作的并发性能。然而,它也存在一些潜在的性能问题,如内存占用增加、写操作性能下降以及频繁的垃圾回收。因此,在使用CopyOnWriteArrayList时,需要根据具体的使用场景进行权衡和选择。在读多写少的场景下,CopyOnWriteArrayList可以发挥出色的性能;而在写操作较为频繁的场景下,可能需要考虑其他线程安全的列表实现。


相关文章
|
2月前
|
Java
线程池是什么?线程池在实际工作中的应用
总的来说,线程池是一种有效的多线程处理方式,它可以提高系统的性能和稳定性。在实际工作中,我们需要根据任务的特性和系统的硬件能力来合理设置线程池的大小,以达到最佳的效果。
67 18
|
3月前
|
人工智能 Java
Java 中数组Array和列表List的转换
本文介绍了数组与列表之间的相互转换方法,主要包括三部分:1)使用`Collections.addAll()`方法将数组转为列表,适用于引用类型,效率较高;2)通过`new ArrayList&lt;&gt;()`构造器结合`Arrays.asList()`实现类似功能;3)利用JDK8的`Stream`流式计算,支持基本数据类型数组的转换。此外,还详细讲解了列表转数组的方法,如借助`Stream`实现不同类型数组间的转换,并附带代码示例与执行结果,帮助读者深入理解两种数据结构的互转技巧。
Java 中数组Array和列表List的转换
|
7月前
|
安全
List并发线程安全问题
【10月更文挑战第21天】`List` 并发线程安全问题是多线程编程中一个非常重要的问题,需要我们认真对待和处理。只有通过不断地学习和实践,我们才能更好地掌握多线程编程的技巧和方法,提高程序的性能和稳定性。
408 59
|
6月前
|
安全 Java 编译器
深入理解Java中synchronized三种使用方式:助您写出线程安全的代码
`synchronized` 是 Java 中的关键字,用于实现线程同步,确保多个线程互斥访问共享资源。它通过内置的监视器锁机制,防止多个线程同时执行被 `synchronized` 修饰的方法或代码块。`synchronized` 可以修饰非静态方法、静态方法和代码块,分别锁定实例对象、类对象或指定的对象。其底层原理基于 JVM 的指令和对象的监视器,JDK 1.6 后引入了偏向锁、轻量级锁等优化措施,提高了性能。
191 3
|
7月前
|
缓存 Java 开发者
Java多线程并发编程:同步机制与实践应用
本文深入探讨Java多线程中的同步机制,分析了多线程并发带来的数据不一致等问题,详细介绍了`synchronized`关键字、`ReentrantLock`显式锁及`ReentrantReadWriteLock`读写锁的应用,结合代码示例展示了如何有效解决竞态条件,提升程序性能与稳定性。
705 6
|
7月前
|
安全 Java
java 中 i++ 到底是否线程安全?
本文通过实例探讨了 `i++` 在多线程环境下的线程安全性问题。首先,使用 100 个线程分别执行 10000 次 `i++` 操作,发现最终结果小于预期的 1000000,证明 `i++` 是线程不安全的。接着,介绍了两种解决方法:使用 `synchronized` 关键字加锁和使用 `AtomicInteger` 类。其中,`AtomicInteger` 通过 `CAS` 操作实现了高效的线程安全。最后,通过分析字节码和源码,解释了 `i++` 为何线程不安全以及 `AtomicInteger` 如何保证线程安全。
182 2
java 中 i++ 到底是否线程安全?
|
6月前
|
监控 Java 数据库连接
Java线程管理:守护线程与用户线程的区分与应用
在Java多线程编程中,线程可以分为守护线程(Daemon Thread)和用户线程(User Thread)。这两种线程在行为和用途上有着明显的区别,了解它们的差异对于编写高效、稳定的并发程序至关重要。
129 2
|
7月前
|
数据采集 存储 数据处理
Python中的多线程编程及其在数据处理中的应用
本文深入探讨了Python中多线程编程的概念、原理和实现方法,并详细介绍了其在数据处理领域的应用。通过对比单线程与多线程的性能差异,展示了多线程编程在提升程序运行效率方面的显著优势。文章还提供了实际案例,帮助读者更好地理解和掌握多线程编程技术。
|
7月前
|
安全 Java 开发者
Java 多线程并发控制:深入理解与实战应用
《Java多线程并发控制:深入理解与实战应用》一书详细解析了Java多线程编程的核心概念、并发控制技术及其实战技巧,适合Java开发者深入学习和实践参考。
167 8
|
7月前
|
存储 监控 安全
深入理解ThreadLocal:线程局部变量的机制与应用
在Java的多线程编程中,`ThreadLocal`变量提供了一种线程安全的解决方案,允许每个线程拥有自己的变量副本,从而避免了线程间的数据竞争。本文将深入探讨`ThreadLocal`的工作原理、使用方法以及在实际开发中的应用场景。
164 2
下一篇
oss创建bucket