当前位置: 首页 > news >正文

JUC下面常见的锁

这里写目录标题

  • 1、ReentrantLock
  • 2、Semaphore
  • 3、CountDownLatch
  • 4、CyclicBarrier

1、ReentrantLock

ReentrantLock 是属于独占模式, 即同一时刻只允许一个线程获取锁。

2、Semaphore

Semaphore 属于共享模式,synchronized 和 ReentrantLock 都是一次只允许一个线程访问某个资源,而Semaphore(信号量)可以用来控制同时访问特定资源的线程数量。

在这里插入图片描述

Semaphore 通常用于那些资源有明确访问数量限制的场景比如限流(仅限于单机模式,实际项目中推荐使用 Redis +Lua 来做限流

Semaphore 的原理:
在这里插入图片描述

3、CountDownLatch

CountDownLatch 允许 count 个线程阻塞在一个地方,直至所有线程的任务都执行完毕。CountDownLatch 是一次性的,计数器的值只能在构造方法中初始化一次,之后没有任何机制再次对其设置值,当 CountDownLatch 使用完毕后,它不能再次被使用。

原理:
CountDownLatch 是共享锁的一种实现,它默认构造 AQS 的 state 值为 count。当线程使用 countDown() 方法时,其实使用了tryReleaseShared方法以 CAS 的操作来减少 state,直至 state 为 0 。当调用 await() 方法的时候,如果 state 不为 0,那就证明任务还没有执行完毕,await() 方法就会一直阻塞,也就是说 await() 方法之后的语句不会被执行。直到count 个线程调用了countDown()使 state 值被减为 0,或者调用await()的线程被中断,该线程才会从阻塞中被唤醒,await() 方法之后的语句得到执行

应用场景:
读取处理 6 个文件,这 6 个任务都是没有执行顺序依赖的任务,但是我们需要返回给用户的时候将这几个文件的处理的结果进行统计整理。

为此我们定义了一个线程池和 count 为 6 的CountDownLatch对象 。使用线程池处理读取任务,每一个线程处理完之后就将 count-1,调用CountDownLatch对象的 await()方法,直到所有文件读取完之后,才会接着执行后面的逻辑。

public class CountDownLatchExample1 {// 处理文件的数量private static final int threadCount = 6;public static void main(String[] args) throws InterruptedException {// 创建一个具有固定线程数量的线程池对象(推荐使用构造方法创建)ExecutorService threadPool = Executors.newFixedThreadPool(10);final CountDownLatch countDownLatch = new CountDownLatch(threadCount);for (int i = 0; i < threadCount; i++) {final int threadnum = i;threadPool.execute(() -> {try {//处理文件的业务操作//......} catch (InterruptedException e) {e.printStackTrace();} finally {//表示一个文件已经被完成countDownLatch.countDown();}});}countDownLatch.await();threadPool.shutdown();System.out.println("finish");}
}

在这里插入图片描述

4、CyclicBarrier

CyclicBarrier 和 CountDownLatch 非常类似,它也可以实现线程间的技术等待,但是它的功能比 CountDownLatch 更加复杂和强大。主要应用场景和 CountDownLatch 类似。

CountDownLatch 的实现是基于 AQS 的,而 CycliBarrier 是基于 ReentrantLock(ReentrantLock 也属于 AQS 同步器)和 Condition 的。

原理:
让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续干活。

在这里插入图片描述

http://www.lryc.cn/news/337471.html

相关文章:

  • Uniapp+基于百度智能云完成AI视觉功能(附前端思路)
  • Android 软件盘的弹出和消失的监听
  • 通俗易懂HTTP和HTTPS区别
  • 【ZZULIOJ】1061: 顺序输出各位数字(Java)
  • java数据结构与算法刷题-----LeetCode260. 只出现一次的数字 III
  • AWS被误扣费了,怎么解决?
  • 再传IPO消息,SHEIN的上市为何充满变数?
  • maven bom
  • 若依vue中关于字典的使用
  • 链表题(哑结点的使用)
  • C#:求三个整数的最大值
  • 广州南沙番禺联想SR530服务器主板传感器故障维修
  • 深入探索自然语言处理:用Python和BERT构建文本分类模型
  • 在Visual Studio Code中编辑React项目时,以下是一些推荐的扩展
  • 智算时代的基础设施如何实现可继承可演进?浪潮云海发布 InCloud OS V8 新一代架构平台
  • LDF、DBC、BIN、HEX、S19、BLF、ARXML、slx等
  • 因为使用ArrayList.removeAll(List list)导致的机器重启
  • Let‘s Encrypt
  • C语言 | Leetcode C语言题解之第24题两两交换链表中的节点
  • 【LeetCode热题100】【回溯】电话号码的字母组合
  • 解析mysql的DDL语句生成高斯内表及表字段主键配置
  • ANSYS Electromagnetics Suite 2023 R2 三维电磁(EM)仿真软件下载
  • pbootcms百度推广链接打不开显示404错误页面
  • springboot 整合 swagger2
  • redis-缓存穿透与雪崩
  • K8S临时存储-本地存储-PV和PVC的使用-动态存储(StorageClass)
  • jeecg-boot安装
  • Unity面经(自整)——移动开发与Shader
  • Nginx实现反向代理、负载均衡、动静分离
  • 【Linux】网络基础(一)