CopyOnWriteArraySet怎么用

在这里插入图片描述

简介

CopyOnWriteArraySet是一个线程安全的无序集合,它基于“写时复制”的思想实现。它继承自AbstractSet,可以将其理解成线程安全的HashSet。

CopyOnWriteArraySet在读取操作比较频繁、写入操作相对较少的情况下可以提高程序的性能和可靠性。它的线程安全机制和CopyOnWriteArrayList一样,是通过volatile和互斥锁实现的。

在这里插入图片描述

应用场景

CopyOnWriteArraySet的应用场景主要是在并发编程中,特别是那些需要高并发的场景。它适用于数据量较小且读多写少的场景,例如,一个Web应用程序中的用户状态信息,这是一个读取操作远多于写入操作的典型场景。

它的线程安全机制避免了在迭代过程中其他线程对集合的修改操作引发的并发冲突,使得在迭代过程中可以安全地进行读取操作。然而,由于CopyOnWriteArraySet的写时复制机制,它可能存在一些性能开销,因此,如果需要频繁的写入操作,可能不适合使用CopyOnWriteArraySet。

总的来说,CopyOnWriteArraySet适合用在读多写少、对数据一致性要求不高、对线程安全性要求高的场景。

在这里插入图片描述

性能问题

CopyOnWriteArraySet的性能问题主要集中在以下几个方面:

  1. 写操作的开销 :由于CopyOnWriteArraySet采用的是写时复制的策略,每次写操作都需要复制一份底层数组,这会导致写操作的开销比较大。如果写操作比较频繁,可能会影响程序的性能。
  2. 内存占用 :由于每次写操作都需要复制一份底层数组,这会导致内存占用比较高。如果集合中的元素数量比较大,可能会导致内存溢出的问题。
  3. 迭代器的性能 :由于CopyOnWriteArraySet的迭代器是基于底层数组的快照实现的,如果在迭代过程中底层数组发生变化,迭代器不会反映这些变化。这可能会导致迭代器的性能不稳定,甚至引发并发问题。

针对以上问题,可以考虑以下优化策略:

  1. 使用其他线程安全集合类 :如果写操作比较频繁,可以考虑使用其他线程安全集合类,如ConcurrentHashMap或ConcurrentSkipListSet等。这些集合类采用了不同的同步策略,可以更好地支持并发访问。
  2. 控制集合的大小 :如果集合中的元素数量比较大,可以考虑控制集合的大小,避免内存溢出的问题。例如,可以设置集合的最大容量,当元素数量超过最大容量时进行清理或压缩操作。
  3. 减少迭代操作 :如果迭代操作比较频繁,可以考虑减少迭代操作的次数或使用其他方式来访问集合中的元素。例如,可以使用流(Stream) API 来处理集合中的元素,避免使用迭代器。

需要注意的是,在选择和优化线程安全集合类时需要根据具体的应用场景和需求进行权衡和选择。

在这里插入图片描述

源码解析

CopyOnWriteArraySet的源码实现相对比较简单,主要基于CopyOnWriteArrayList实现。以下是对CopyOnWriteArraySet源码的简单讲解:

public class CopyOnWriteArraySet<E> extends AbstractSet<E> {
    private final List<E> array;

    public CopyOnWriteArraySet() {
        this.array = new CopyOnWriteArrayList<>();
    }

    @Override
    public boolean add(E e) {
        return array.add(e);
    }

    @Override
    public boolean remove(Object o) {
        return array.remove(o);
    }

    @Override
    public boolean contains(Object o) {
        return array.contains(o);
    }

    @Override
    public int size() {
        return array.size();
    }

    @Override
    public Iterator<E> iterator() {
        return new COWIterator<>(array.listIterator());
    }
}

在CopyOnWriteArraySet中,所有的操作都是通过调用CopyOnWriteArrayList的实现来完成的。CopyOnWriteArrayList的实现细节可以参考之前对CopyOnWriteArrayList的讲解。其中,COWIterator是一个简单的迭代器实现,用于包装ListIterator并确保线程安全。在迭代过程中,COWIterator会持有一个快照,不允许修改操作。

在这里插入图片描述

扩容机制

CopyOnWriteArraySet的扩容机制是基于CopyOnWriteArrayList实现的。当集合的元素数量超过当前数组的容量时,会创建一个新的数组,然后将原数组中的元素复制到新数组中。这个过程是线程安全的,因为整个复制过程是一个原子操作。

具体的扩容过程如下:

  1. 当集合的元素数量超过当前数组的容量时,会创建一个新的数组,大小是原数组的两倍。
  2. 然后将原数组中的元素复制到新数组中,每个元素复制的顺序是按照它们在原数组中的顺序。
  3. 复制完成后,将原数组清空,并将新数组赋值给集合的内部数组。

这种扩容机制的优点是可以在多线程环境下实现高效的并发访问,因为复制操作是一个原子操作,不会受到其他线程的干扰。同时,由于每次扩容时都会创建一个新的数组,因此可以避免因为元素插入导致的数组重新排列的开销。但是,由于每次扩容都需要创建一个新的数组并复制元素,所以如果集合中的元素数量非常大,扩容过程可能会比较耗时。

与CopyOnWriteArrayList的区别

CopyOnWriteArraySet和CopyOnWriteArrayList都是基于“写时复制”的思想实现的线程安全的数据结构,适用于读多写少的场景。它们的主要区别在于:

  1. 数据结构:CopyOnWriteArraySet是Set,而CopyOnWriteArrayList是List。因此,CopyOnWriteArraySet不允许存放重复值,而CopyOnWriteArrayList可以。
  2. 存储方式:CopyOnWriteArraySet内部持有一个CopyOnWriteArrayList引用,所有的操作都是由CopyOnWriteArrayList来实现的。它是无序的,不允许存放重复值。
  3. 迭代器行为:CopyOnWriteArraySet的迭代器使用了“快照”技术,存储了内部数组快照,不支持remove、set、add操作,但通过迭代器进行并发读取时效率很高。这是与CopyOnWriteArrayList的主要区别。

两者都是线程安全的数据结构,适用于读多写少的场景。主要区别在于数据结构、存储方式和迭代器行为。

代码示例

在多线程环境下,可以使用CopyOnWriteArraySet来保证线程安全。以下是一个简单的示例:

import java.util.concurrent.CopyOnWriteArraySet;

public class Example {
    private static CopyOnWriteArraySet<String> set = new CopyOnWriteArraySet<>();

    public static void main(String[] args) {
        new Thread(() -> {
            for (int i = 0; i < 5000; i++) {
                set.add("a" + System.currentTimeMillis());
            }
        }).start();

        new Thread(() -> {
            for (int i = 0; i < 5000; i++) {
                set.add("b" + System.currentTimeMillis());
            }
        }).start();
    }
}

在这个示例中,我们创建了一个CopyOnWriteArraySet,并启动了两个线程,每个线程都向集合中添加元素。由于CopyOnWriteArraySet是线程安全的,因此在迭代过程中,其他线程对集合的修改操作不会引发并发冲突。

在这里插入图片描述

拓展

  • 线程安全集合类
    除了CopyOnWriteArraySet和CopyOnWriteArrayList,Java中还有其他一些线程安全的集合类,包括:
  1. ConcurrentHashMap:线程安全的Map实现,使用分段锁技术实现并发访问。
  2. ConcurrentSkipListMap:基于跳表(Skip List)实现的线程安全Map,具有较高的并发性能。
  3. ConcurrentLinkedQueue:基于链接节点的线程安全队列,支持高效的并发访问。
  4. ConcurrentSkipListSet:基于跳表(Skip List)实现的线程安全Set,具有较高的并发性能。

这些线程安全集合类的使用方法和普通的集合类类似,但它们能够在多线程环境下提供更好的并发性能和数据安全性。

  • CopyOnWriteArrayList讲解
    快点我呀✋🏻

  • 更多集合

ConcurrentLinkedDeque详解-Deque接口链表实现方案

ArrayDeque详解-Deque接口数组实现方案

LinkedList详解-Deque接口链表实现方案

Java中Deque接口方法解析

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/226661.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Rook-ceph(1.12.9最新版)

官网的步骤 git clone --single-branch --branch v1.12.9 https://github.com/rook/rook.git cd rook/deploy/examples kubectl create -f crds.yaml -f common.yaml -f operator.yaml kubectl create -f cluster.yaml整理后的已经替换好的国内镜像的 git clone https://gite…

C++——内部类

class A { public:class B//内部类{private:int _b;}; private:int _a; }; int main() {cout << sizeof(A) << endl;return 0; } 概念及特征&#xff1a; 如果一个类定义在另一个类的内部&#xff0c;这个类就叫内部类。注意此时这个内部类是一个独立的类&#x…

前缀和 LeetCode1423. 可获得的最大点数

几张卡牌 排成一行&#xff0c;每张卡牌都有一个对应的点数。点数由整数数组 cardPoints 给出。 每次行动&#xff0c;你可以从行的开头或者末尾拿一张卡牌&#xff0c;最终你必须正好拿 k 张卡牌。 你的点数就是你拿到手中的所有卡牌的点数之和。 给你一个整数数组 cardPoi…

图的广度优先搜索(数据结构实训)

题目&#xff1a; 图的广度优先搜索 描述&#xff1a; 图的广度优先搜索类似于树的按层次遍历&#xff0c;即从某个结点开始&#xff0c;先访问该结点&#xff0c;然后访问该结点的所有邻接点&#xff0c;再依次访问各邻接点的邻接点。如此进行下去&#xff0c;直到所有的结点都…

Python实现的二叉树的先序、中序、后序遍历示例

一、先序、中序、后序遍历的次序&#xff1a; 创建好一棵二叉树后&#xff0c;可以按照一定的顺序对树中所有的元素进行遍历。按照先左后右&#xff0c;树 的遍历方法有三种&#xff1a;先序遍历、中序遍历和后序遍历。 其中&#xff0c;先序遍历的次序是&#xff1a;如果二叉…

Javascript编程进阶 – 预定义函数

Javascript编程进阶 – 预定义函数 JavaScript Programming Advanced – Predefined Functions By JacksonML JavaScript引擎中包含了一组built-in functions(内建函数)。 本文简要介绍如何通过实践使用这些预定义函数并掌握传递参数和返回值。希望对您有所帮助。 JavaScri…

C语言课程设计

内容与设计思想 1、系统功能与分析&#xff08;填写你所设计的菜单及流程图&#xff09;。 菜单&#xff1a; 日历打印 日历推算 日历间隔倒计时牌 退出程序 模块设计 根据功能需要&#xff1a; 源文件&#xff1a; #include<stdio.h> #include&…

Light-Head R-CNN: In Defense of Two-Stage Object Detector(2017.11)

文章目录 Abstract1. Introduction2. Related works3. Our Approach3.1. Light-Head R-CNN3.1.1. R-CNN subnet3.1.2. Thin feature maps for RoI warping 3.2. Light-Head R-CNN for Object Detection Conclusion 原文链接 Abstract 在本文中&#xff0c;我们首先研究了为什么…

参考信号速度变化存在跳跃时容易发生不稳定的阻抗调节

问题描述 当参考信号速度存在跳跃变化时&#xff0c;阻抗调节系统容易发生不稳定。这是因为阻抗调节系统需要根据参考信号的速度来调整其输出阻抗&#xff0c;以匹配负载阻抗&#xff0c;从而保持系统的稳定性。 当参考信号速度突然变化时&#xff0c;阻抗调节系统可能无法及…

【QML】QML与cpp交互(一)—— QML直接调用cpp函数

目录 1、cpp 创建一个类 2、将类对象暴露给QML 3、QML通过对象直接调用cpp函数 1、cpp 创建一个类 类模板如下: #include <QtCore/QObject>class vacUdpClient: public QObject {Q_OBJECT public: vacUdpClient(QObject* parent nullptr): QObject(parent) {}// Q…

hive-3.1.2环境安装实验

1.修改hadoop相关参数 1-修改core-site.xml [bigdata@master hive]$ vim /opt/module/hadoop/etc/hadoop/core-site.xml <!-- 配置该bigdata(superUser)允许通过代理访问的主机节点 --><property><name>hadoop.proxyuser.bigdata.hosts</name><va…

[VSCode] Java开发环境配置

文章目录 1 VSCode & Java 安装1.1 安装 VSCode1.2 安装 JDK 2 环境变量配置3 在 VSCode 中安装 Java 扩展4 运行测试 1 VSCode & Java 安装 1.1 安装 VSCode Visual Studio Code 官方下载 地址&#xff1a; https://code.visualstudio.com/详细安装步骤这里不做赘…

笔记本用gpu运行tensorflow-gpu,keras写的老程序,结果与原来不一样,一脸懵逼。

先说结论我笔记一是rtx3050ti, 重点RTX30系列最低要求CUDA版本为11.1&#xff0c;否则最后跑程序会报错。再说现象&#xff0c;突发奇想想在笔记本上运行一个以前在1080titensorflow-gpu1.5.2,keras2.2.4上面写的一个图像分类模型&#xff0c;先用cpu模式 运行一下一切正常。如…

利用proteus实现串口助手和arduino Mega 2560的串口通信

本例用到的proteus版本为8.13&#xff0c;ardunio IDE版本为2.2.1&#xff0c;虚拟串口vspd版本为7.2&#xff0c;串口助手SSCOM V5.13.1。软件的下载安装有很多教程&#xff0c;大家可以自行搜索&#xff0c;本文只介绍如何利用这4种软件在proteus中实现arduino Mega 2560的串…

全志H6-ARMLinux第1天:全志概述、刷机登陆、官方外设库、蜂鸣器、超声波测距

1. 全志H616课程概述&#xff08;456.01&#xff09; 1.1 为什么学 学习目标依然是Linux系统&#xff0c;平台是ARM架构 蜂巢快递柜&#xff0c;配送机器人&#xff0c;这些应用场景用 C51、STM32 单片机无法实现第三方介入库的局限性&#xff0c;比如刷脸支付和公交车收费设…

分布式系统理论基础

目录 引言 CAP定理 CAP的工程启示 1、关于 P 的理解 2、CA非0/1的选择 3、跳出CAP 小结 本文转自&#xff1a;https://www.cnblogs.com/bangerlee/p/5328888.html 该系列博文会告诉你什么是分布式系统&#xff0c;这对后端工程师来说是很重要的一门学问&#xff0c;我们会逐步了…

报表多源关联

报表多源关联 需求背景 在项目中会遇到多种数据展现在一起的报表。例如部分指标在关系型数据库中&#xff0c;部分指标通过restful接口获得到json&#xff0c;然后根据共同的维度关联一起&#xff0c;形成新的数据集。 解决方案 在硕迪报表中有两种方式实现该多源报表&…

MySQL数据库从小白到入门(二)

多表关系&#xff1a; 项目开发中&#xff0c;在进行数据库表结构设计时&#xff0c;会根据业务需求及业务模块之间的关系&#xff0c;分析并设计表结构。由于业务之间相互关联&#xff0c;所以各个表结构之间也存在着各种联系&#xff0c;基本上分为三种。 外键&#xff1a; 创…

优思学院|六西格玛质量管理的工具、方法和手段

质量管理涉及多种技术不同的手段&#xff0c;包括了理性分析的和数据分析的工具&#xff0c;绝大部分工具都可以在六西格玛绿带和黑带知识领域中找到&#xff0c;因此&#xff0c;质量人应该学好六西格玛。以下&#xff0c;我们列举一些常见的技术手段。 六西格玛项目方法&…

单片机学习13——串口通信

单片机的通信功能&#xff1a; 实现单片机和单片机的信息交换&#xff0c;实现单片机和计算机的信息交换。 计算机通信是指计算机与外部设备或计算机与计算机之间的信息交换。 通信有并行通信和串行通信两种方式。 在多微机系统以及现在测控系统中信息的交换多采用串行通信方…