并发控制艺术：掌握CountDownLatch与Semaphore资源-CSDN文库

共3个文件

pdf：2个

png：1个

编程语言

软件工程

hystrix

需积分: 1 169 浏览量 2023-12-12 19:55:34 上传评论收藏 1.23MB ZIP 举报

资源推荐

资源详情

资源评论

收起资源包目录

并发控制艺术：掌握CountDownLatch与Semaphore.zip （3个子文件）

并发编程之CountDownLatch&Semaphore原理与应用1.pdf 536KB

并发编程之CountDownLatch&Semaphore原理与应用.pdf 535KB

ͼ.png 231KB

1.Semaphore是什么？

2.怎么使用Semaphore？

2.1构造方法

2.2重要方法

2.3基本使用

2.3.1需求场景

2.3.2代码实现

CountDownLatch使用及应用场景例子

CountDownLatch是什么？

CountDownLatch如何工作？

CyclicBarrier

Executors

Exchanger

1.Semaphore是什么？

Semaphore字面意思是信号量的意思，它的作用是控制访问特定资源的线程数目，底层依

赖AQS的状态State，是在生产当中比较常用的一个工具类。

2.怎么使用Semaphore？

2.1构造方法

1 publicSemaphore(intpermits)

2 publicSemaphore(intpermits,booleanfair)

permits表示许可线程的数量

fair表示公平性，如果这个设为true的话，下次执行的线程会是等待最久的线

程

2.2重要方法

1 publicvoidacquire()throwsInterruptedException

2 publicvoidrelease()

3 tryAcquire（longtimeout,TimeUnitunit）

acquire()表示阻塞并获取许可

release()表示释放许可

2.3基本使用

2.3.1需求场景

资源访问，服务限流(Hystrix里限流就有基于信号量方式)。

2.3.2代码实现

1 publicclassSemaphoreRunner{

2 publicstaticvoidmain(String[]args){

3 Semaphoresemaphore=newSemaphore(2);

4 for(inti=0;i<5;i++){

5 newThread(newTask(semaphore,"yangguo+"+i)).start();

6 }

7 }

8 

9 staticclassTaskextendsThread{

10 Semaphoresemaphore;

11 

12 publicTask(Semaphoresemaphore,Stringtname){

13 this.semaphore=semaphore;

14 this.setName(tname);

15 }

16 

17 publicvoidrun(){

18 try{

19 semaphore.acquire();

20 System.out.println(Thread.currentThread().getName()+":aquire()

attime:"+System.currentTimeMillis());

21 Thread.sleep(1000);

22 semaphore.release();

23 System.out.println(Thread.currentThread().getName()+":aquire()

attime:"+System.currentTimeMillis());

24 }catch(InterruptedExceptione){

25 e.printStackTrace();

26 }

27 

28 }

29 }

30 }

打印结果：

Thread-3:aquire() at time:1563096128901

Thread-1:aquire() at time:1563096128901

Thread-1:aquire() at time:1563096129903

Thread-7:aquire() at time:1563096129903

Thread-5:aquire() at time:1563096129903

Thread-3:aquire() at time:1563096129903

Thread-7:aquire() at time:1563096130903

Thread-5:aquire() at time:1563096130903

Thread-9:aquire() at time:1563096130903

Thread-9:aquire() at time:1563096131903

从打印结果可以看出，一次只有两个线程执行acquire()，只有线程进行release()方法后

才会有别的线程执行acquire()。

CountDownLatch使用及应用场景例子

CountDownLatch是什么？

CountDownLatch这个类能够使一个线程等待其他线程完成各自的工作后再执行。例

如，应用程序的主线程希望在负责启动框架服务的线程已经启动所有的框架服务之后再执

行。

使用场景：

Zookeeper分布式锁,Jmeter模拟高并发等

CountDownLatch如何工作？

CountDownLatch是通过一个计数器来实现的，计数器的初始值为线程的数量。每当

一个线程完成了自己的任务后，计数器的值就会减1。当计数器值到达0时，它表示所有的

线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。

API

1 CountDownLatch.countDown()

2 CountDownLatch.await();

CountDownLatch应用场景例子

比如陪媳妇去看病。

医院里边排队的人很多，如果一个人的话，要先看大夫，看完大夫再去排队交钱取药。

现在我们是双核，可以同时做这两个事（多线程）。

评论收藏

内容反馈

光芒软件工匠

粉丝: 790
资源: 64

并发控制艺术：掌握CountDownLatch与Semaphore

Java并发编程一CountDownLatch、CyclicBarrier、Semaphore初使用

CountDownLatch、Semaphore等4大并发工具类详解

Java并发编程：CountDownLatch与CyclicBarrier和Semaphore的实例详解

并发编程之Tools&CountDownLatch&Semaphore原理与应用1

java并发工具类（CountDownLatch+Semaphore+Exchanger）

2023年最新Java高并发多线程面试题

java并发之并发工具类

Java 并发编程原理与实战视频

龙果java并发编程完整视频

java并发编程

龙果 java并发编程原理实战

Java并发编程学习笔记

CountDownLatch、CyclicBarrier、Semaphore.md

Java并发编程原理与实战

JUC多线程学习个人笔记

Java多线程之并发工具类

Java并发编程应该掌握的并发工具类，快来看看你掌握了哪些？

KepOPC DA2UA实现从OPCDA到OPCUA的转换及读写互操作

kkFileView-4.4.0-SNAPSHOT.tar.gz

“未来工厂”建设导则.pdf

2024年Java基础面试题，附带详细解析答案

腾讯QQ秀立项调研PPT

各省互联网普及率（1997-2020）

5G介绍PPT.pptx

海盗派测试分析.pdf

2024年最新最全面的Java后端面试资料

CHATGPT训练指令模板.docx

基于SpringBoot的个人博客系统设计与实现-论文.pdf

全国31省份各省数字经济水平测算熵值法+主成分测算原始数据+结果（2011-2022年）

最新资源