高并发编程系列:4大并发工具类的功能、原理、以及应用场景
通常我们所说的并发包也就是java.util.concurrent,集中了Java并发工具类和并发容器等,今天主要介绍Java并发编程的工具类,我先从Java并发工具包谈起。
01
—
并发工具包涵盖范围
1.并发工具类
提供了比synchronized更加高级的各种同步结构:包括CountDownLatch、CyclicBarrier、Semaphore等,可以实现更加丰富的多线程操作。
2.并发容器
提供各种线程安全的容器:最常见的ConcurrentHashMap、ConcurrentSkipListMap,实现线程安全的动态数组CopyOnWriteArrayList等。
3.并发队列
各种BlockingQueue的实现:常用的ArrayBlockingQueue、SynchorousQueue、特定场景的PriorityBlockingQueue。
4.Executor框架
可以创建各种不同类型的线程池,调度任务运行等,绝大部分情况下,不再需要自己从头实现线程池和任务调度器。
02
—
常用的并发容器
1.ConcurrentHashMap
经常使用的并发容器,JDK 1.7和1.8的底层数据结构发生了变化(后续文章会详解),这里可以建议学习顺序如下:从Java7 HashMap -> Java7 ConcurrentHashMap -> Java8 HashMap -> Java8 ConcurrentHashMap,这样可以更好的掌握这个并发容器,毕竟都是从HashMap进化而来。
2.ConcurrentSkipListMap
在乎顺序,需要对数据进行非常频繁的修改
3.CopyOnWrite容器
CopyOnWrite容器即写时复制的容器。从JDK1.5开始Java并发包里提供了两个使用CopyOnWrite机制实现的并发容器,CopyOnWriteArrayList和CopyOnWriteArraySet。
4.各种并发队列的实现
如各种BlockedQueue实现,比较典型的ArrayBlockingQueue、SynchorousQueue。
03
—
常用的并发工具类
1.CountDownLatch
功能:
CountDownLatch是一个同步的辅助类,允许一个或多个线程,等待其他一组线程完成操作,再继续执行。
原理:
CountDownLatch是通过一个计数器来实现的,计数器的初始值为需要等待线程的数量。
eg:CountDownLatch c = new CountDownLatch(10); // 等待线程的数量为10
主线程调用CountDownLatch的await()方法会阻塞当前线程(即:主线程在闭锁上等待),直到计数器的值为0。
当一个工作线程完成了自己的任务后,调用CountDownLatch的countDown()方法,计数器的值就会减1。
当计数器值为0时,说明所有的工作线程都执行完了,此时,在闭锁上等待的主线程就可以恢复执行任务。
应用场景:
倒数计时器
例如:一种典型的场景就是火箭发射。在火箭发射前,为了保证万无一失,往往还要进行各项设备、仪器的检查。 只有等所有检查完毕后,引擎才能点火。这种场景就非常适合使用CountDownLatch。
它可以使得点火线程,等待所有检查线程全部完工后,再执行
使用方式:
static final CountDownLatch end = new CountDownLatch(10);end.countDown();
end.await();
2.CyclicBarrier
功能:
CyclicBarrier的字面意思是可循环使用(Cyclic)的屏障(Barrier)。它要做的事情是,让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续运行。
和CountDownLatch相似,也是等待某些线程都做完以后再执行。
与CountDownLatch区别:
在于这个计数器可以反复使用。比如,假设我们将计数器设置为10。那么凑齐第一批1 0个线程后,计数器就会归零,然后接着凑齐下一批10个线程。
原理:
1)CyclicBarrier是通过一个计数器来实现的,计数器的初始值为需要等待线程的数量。eg:CyclicBarrier c = new CyclicBarrier(2); // 等待线程的数量为2
2)每个线程调用CyclicBarrier的await()方法,使自己进入等待状态。
3)当所有的线程都调用了CyclicBarrier的await()方法后,所有的线程停止等待,继续运行。
使用方式:
public CyclicBarrier(int parties, Runnable barrierAction)
barrierAction就是当计数器一次计数完成后,系统会执行的动作await()
3.信号量Semaphore
功能:
Java提供了经典信号量Semaphore的实现,它通过控制一定数量的许可(permit)的方式,来达到限制通用资源访问的目的。例如:控制并发的线程数。
原理:
1)Semaphore是通过一个计数器(记录许可证的数量)来实现的,计数器的初始值为需要等待线程的数量。
eg:Semaphore s = new Semaphore(10); // 线程最大的并发数为10
2)线程通过acquire()方法获取许可证(计数器的值减1),只有获取到许可证才可以继续执行下去,否则阻塞当前线程。
3)线程通过release()方法归还许可证(计数器的值加1)。
说明:使用tryAcquire()方法可以立即得到执行的结果:尝试获取一个许可证,若获取成功,则立即返回true,若获取失败,则立即返回false。
应用场景:
Semaphore可以用于做流量控制,特别是公用资源有限的应用场景,比如数据库连接。
举一个场景:例如在车站、机场等出租车时,当很多空出租车就位时,为防止过度拥挤,调度员指挥排队等待坐车的队伍一次进来5个人上车,等这5个人坐车出发,再放进去下一批。这和Semaphore的工作原理有些类似。
4.交换者Exchanger
功能:
Exchanger(交换者)是一个用于线程间协作的工具类。Exchanger用于进行线程间的数据交换。
原理:
它提供一个同步点,在这个同步点两个线程可以交换彼此的数据。
这两个线程通过exchange方法交换数据, 如果第一个线程先执行exchange方法,它会一直等待第二个线程也执行exchange,当两个线程都到达同步点时,这两个线程就可以交换数据,将本线程生产出来的数据传递给对方。
Exchanger的应用场景
Exchanger可以用于校对工作的场景。
高并发编程系列:4大并发工具类的功能、原理、以及应用场景相关推荐
- 并发编程系列之线程池工厂类:Executors
前言 上节讲了讲自定义线程池,今天我们来聊聊线程池框架,在实际开发中我们还是基本使用线程框架Executor给我们提供的一些工具类,Java提供的Executor都在JUC(java.util.con ...
- Java并发编程系列
Java并发编程系列 2018-03-08 Java 并发编程:核心理论 Java并发编程:Synchronized及其实现原理 Java并发编程:Synchronized底层优化(轻量级锁.偏向锁) ...
- 高并发编程系列:NIO、BIO、AIO的区别,及NIO的应用和框架选型
谈到并发编程就不得不提到NIO,以及相关的Java NIO框架Netty等,并且在很多面试中也经常提到NIO和AIO.同步和异步.阻塞和非阻塞等的区别.我先简短介绍下几个NIO相关的概念,然后再谈NI ...
- java并发实战编程pdf_「原创」Java并发编程系列25 | 交换器Exchanger
2020年Java面试题库连载中 [000期]Java最全面试题库思维导图 [001期]JavaSE面试题(一):面向对象 [002期]JavaSE面试题(二):基本数据类型与访问修饰符 [003期] ...
- reentrantlock非公平锁不会随机挂起线程?_【原创】Java并发编程系列16 | 公平锁与非公平锁...
本文为何适原创并发编程系列第 16 篇,文末有本系列文章汇总. 上一篇提到重入锁 ReentrantLock 支持两种锁,公平锁与非公平锁.那么这篇文章就来介绍一下公平锁与非公平锁. 为什么需要公平锁 ...
- Java 并发编程系列之带你了解多线程
早期的计算机不包含操作系统,它们从头到尾执行一个程序,这个程序可以访问计算机中的所有资源.在这种情况下,每次都只能运行一个程序,对于昂贵的计算机资源来说是一种严重的浪费. 操作系统出现后,计算机可以运 ...
- java 线程钩子_高级并发编程系列六(线程池钩子函数)
1.考考你 国庆假期快要结束了,准备回到工作岗位的你,是不是已经开始撸起袖子敲代码,反正发完文章我就要准备去加班了,程序员就这样,有干劲对吧 那么来吧,让我们一起分享完高级并发编程系列中,线程池小节的 ...
- 并发编程系列之一:锁的意义
背景 C/C++语言的并发程序(Concurrent Programming)设计,一直是一个比较困难的话题.很多朋友都会尝试使用多线程编程,但是却很难保证自己所写的多线程程序的正确性.多线程程序,如 ...
- 并发编程系列之什么是Java内存模型?
并发编程系列之什么是Java内存模型? 1.什么是Java的内存模型 Java内存模型简称JMM(Java Memory Model),JMM是和多线程并发相关的一组规范.各个jvm实现都要遵循这个J ...
- 学习ASP.NET Core Razor 编程系列十八——并发解决方案
原文:学习ASP.NET Core Razor 编程系列十八--并发解决方案 学习ASP.NET Core Razor 编程系列目录 学习ASP.NET Core Razor 编程系列一 学习ASP. ...
最新文章
- visual studio C语言指针提示:使用未初始化的内存xx
- axure html显示效果,Axure RP基础篇: 实现循环显示效果的两种方法
- 快速上手Google C++ 测试框架googletest
- 【超详细整理数组基础知识点】(学习笔记8--数组上)
- 被阿里带火的数据中台:“大中台、小前台”战略是什么?
- mysql数据库主从出现1236错误
- 长按UIWebView上的图片保存到相册
- f4小组专用3306mysql抓鸡工具_【技术】3306端口手动入侵之mysql写入启动项提权
- Windows and CentOS IPv4转IPv6隧道方法
- 读取cpu温度的api_温度读取vc++获取cpu温度
- html nav标签无序排列,web前端分享HTML5中的nav标签
- HarmonyOS(鸿蒙)——单击事件
- ASP Err.Number 错误描述详解
- Vue 图片懒加载 v-lazy
- 【微信小程序开发日记01】和风天气OUC之初步构想
- 凯文·凯利:最伟大的产品还没有被创造出来
- 使用 HTML CSS 编辑静态网页
- pon终端测试仪_PON产品测试方案
- DNS 缓存查看以及清除(转载)
- Django基础教程
热门文章
- 微码汇:微营销实战经验全集(下篇)
- 计算机毕业设计Java儿童教育系统(源码+系统+mysql数据库+lW文档)
- LADA:Local Additivity Based Data Augmentation for Semi-supervised NER理解
- ubuntu raid0_如何在Ubuntu上为简单文件服务器设置软件RAID
- Web入侵之利用编辑器漏洞入侵
- 计算机病毒及危害教案,计算机病毒及预防教案
- python不可以处理pdf文件_PyPDF2 write不能用于某些PDF文件(Python3.5.1)
- MATLAB信号处理---学习小案例(8)---Z变换概述
- Vue开发环境搭建及在docs新建vue项目
- 解决eNSP路由器打开命令行界面(CLI)一直输出“###”的问题(大合集)