有关List的线程安全、高效读取:不变模式下的CopyOnWriteArrayList类、数据共享通道:BlockingQueue

本文主要是介绍有关List的线程安全、高效读取:不变模式下的CopyOnWriteArrayList类、数据共享通道:BlockingQueue,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!


有关List的线程安全

队列、链表之类的数据结构也是极常用的,几乎所有的应用程序都会与之相关。在java中,
ArrayList和Vector都使用数组作为其内部实现。两者最大的不同在与Vector是线程安全的。
而ArrayList不是。此外LinkedList使用链表的数据结构实现了List。但是LinkedList并
不是线程安全的。参考对HashMap的包装,这里我们也可用用Collections.synchronizedList
方法来包装任意List:
public static List<String> l = Collections.synchronizedList(new LinkedList<String>());
此时生成的List对象就是线程安全的了。

ConcurrentLinkedQueue来实现高并非的队列。应该算是高并发环境中性能最好的队列。
它之所以很好性能,是因为其内部复杂的实现。这个方法没有任何锁操作。
线程安全完全由CAS操作和队列的算法来保证。整个方法的核心是for循环。
这个循环没有出口,直到尝试成功。这也符合CAS操作的流程。

高效读取:不变模式下的CopyOnWriteArrayList类

在很多应用场景中,读操作可能会远远大于写操作。
比如,有些系统级别的信息,往往只需要加载或者修改很少的次数,但是
会被系统内所有模块频繁访问。
由于读操作根本不会修改原有的数据,因此对于每次读取都进行加锁其实是一种
资源浪费。JDK中提供了CopyOnWriteArrayList类,对它来说,读取是完全不用
加锁的,并且更好的消息是,写入也不会阻塞读取操作。只有写入和写入之间需要
进行同步等待。

数据共享通道:BlockingQueue
前面提到了ConcurrentLinkedQueue类是高性能的队列。对于并发程序而言,
高性能自然是一个我们需要追求的目标,但多线程开发模式还会引入一个问题,
那就是如何进行多个线程间的数据共享呢?比如,线程A希望给线程B发一条消息
用什么方式告知线程B是比较合理的呢?
一般来说,我们总希望整个系统是松散耦合的。
比如,你所在小区的物业希望可用得到一些业主的意见,设立一个
意见箱,如果对物业有任何要求或意见都可用投到意见箱里。
如果对物业有任务要求或者意见都可用投到意见箱里。
作为业主的你并不需要直接找到物业相关的工作人员
就能表达意见。实际上,物业的工作人员也可能经常发生变动。
直接找工作人员未必是一件方便的事情。而你投递到意见箱的意见总是
会被物业的工作人员看到,不管是否发生了人员的变动。
这样你就可用很容易地表达自己的诉求了。
你既不需要直接和他们对话,又可用轻松提出自己的建议。

将这个模式映射到我们程序中,就是说我们既希望线程A能够通知线程B,
又希望线程A不知道线程B的存在。这样,如果将来进行重构或者升级,
我们完全可用不修改线程A,而直接把线程B升级为线程B,
保证系统的平滑过度。而这中间的意见箱就可用使用BlockingQueue来实现。

与之前提到的ConcurrentLinkedQueue类或者CopyOnWriteArrayList类不同,
BlockingQueue是一个接口,并非一个具体的实现。
ArrayBlockingQueue类和LinkedBlockingQueue类。
ArrayBlockingQueue更适合做有界队列,
LinkedBlockingQueue适合做无界队列。
BlockingQueue之所以适合作为数据共享的通道,其关键在于
Blocking上,Blocking是阻塞的意思,但服务线程(服务线程指
不断获取队列中的消息,进行处理的线程)处理完成队列中所有的消息后,
它如何知道下一条消息何时到来呢?
一种简单的做法是让这个线程按照一定的时间间隔不停地循环和监控这个队列。
这是一种可行的方案,但显然造成了不必要的资源浪费。
而且循环周期也难以确定。
BlockingQueue很好地解决了这个问题。它会让服务线程在队列为空时
进行等待,当有新的消息进入队列后,自动将线程唤醒。

这篇关于有关List的线程安全、高效读取:不变模式下的CopyOnWriteArrayList类、数据共享通道:BlockingQueue的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/531139

相关文章

Java中如何正确的停掉线程

《Java中如何正确的停掉线程》Java通过interrupt()通知线程停止而非强制,确保线程自主处理中断,避免数据损坏,线程池的shutdown()等待任务完成,shutdownNow()强制中断... 目录为什么不强制停止为什么 Java 不提供强制停止线程的能力呢?如何用interrupt停止线程s

Redis实现高效内存管理的示例代码

《Redis实现高效内存管理的示例代码》Redis内存管理是其核心功能之一,为了高效地利用内存,Redis采用了多种技术和策略,如优化的数据结构、内存分配策略、内存回收、数据压缩等,下面就来详细的介绍... 目录1. 内存分配策略jemalloc 的使用2. 数据压缩和编码ziplist示例代码3. 优化的

python 线程池顺序执行的方法实现

《python线程池顺序执行的方法实现》在Python中,线程池默认是并发执行任务的,但若需要实现任务的顺序执行,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋... 目录方案一:强制单线程(伪顺序执行)方案二:按提交顺序获取结果方案三:任务间依赖控制方案四:队列顺序消

使用SpringBoot+InfluxDB实现高效数据存储与查询

《使用SpringBoot+InfluxDB实现高效数据存储与查询》InfluxDB是一个开源的时间序列数据库,特别适合处理带有时间戳的监控数据、指标数据等,下面详细介绍如何在SpringBoot项目... 目录1、项目介绍2、 InfluxDB 介绍3、Spring Boot 配置 InfluxDB4、I

使用Java读取本地文件并转换为MultipartFile对象的方法

《使用Java读取本地文件并转换为MultipartFile对象的方法》在许多JavaWeb应用中,我们经常会遇到将本地文件上传至服务器或其他系统的需求,在这种场景下,MultipartFile对象非... 目录1. 基本需求2. 自定义 MultipartFile 类3. 实现代码4. 代码解析5. 自定

C#高效实现Word文档内容查找与替换的6种方法

《C#高效实现Word文档内容查找与替换的6种方法》在日常文档处理工作中,尤其是面对大型Word文档时,手动查找、替换文本往往既耗时又容易出错,本文整理了C#查找与替换Word内容的6种方法,大家可以... 目录环境准备方法一:查找文本并替换为新文本方法二:使用正则表达式查找并替换文本方法三:将文本替换为图

Python如何实现高效的文件/目录比较

《Python如何实现高效的文件/目录比较》在系统维护、数据同步或版本控制场景中,我们经常需要比较两个目录的差异,本文将分享一下如何用Python实现高效的文件/目录比较,并灵活处理排除规则,希望对大... 目录案例一:基础目录比较与排除实现案例二:高性能大文件比较案例三:跨平台路径处理案例四:可视化差异报

Java整合Protocol Buffers实现高效数据序列化实践

《Java整合ProtocolBuffers实现高效数据序列化实践》ProtocolBuffers是Google开发的一种语言中立、平台中立、可扩展的结构化数据序列化机制,类似于XML但更小、更快... 目录一、Protocol Buffers简介1.1 什么是Protocol Buffers1.2 Pro

Java高效实现Word转PDF的完整指南

《Java高效实现Word转PDF的完整指南》这篇文章主要为大家详细介绍了如何用Spire.DocforJava库实现Word到PDF文档的快速转换,并解析其转换选项的灵活配置技巧,希望对大家有所帮助... 目录方法一:三步实现核心功能方法二:高级选项配置性能优化建议方法补充ASPose 实现方案Libre

Java List 使用举例(从入门到精通)

《JavaList使用举例(从入门到精通)》本文系统讲解JavaList,涵盖基础概念、核心特性、常用实现(如ArrayList、LinkedList)及性能对比,介绍创建、操作、遍历方法,结合实... 目录一、List 基础概念1.1 什么是 List?1.2 List 的核心特性1.3 List 家族成