带你看看Java的锁(二)-Semaphore
66 浏览量
2020-12-21
14:16:58
上传
评论
收藏 126KB PDF 举报
带你看看带你看看Java的锁的锁(二二)-Semaphore
带你看看带你看看Java的锁的锁-Semaphore前言简介使用源码分析类结构图SyncNonfairSyncFairSyncSemaphore 构造函数Semaphore
成员方法获取释放总结
前言前言
简介简介
Semaphore 中文称信号量，它和ReentrantLock 有所区别，ReentrantLock是排他的，也就是只能允许一个线程拥有资
源，Semaphore是共享的，它允许多个线程同时拥有资源，是AQS中共享模式的实现，在前面的AQS分析文章中，我也是用
Semaphore去解释共享锁的
现实中，我们火爆一点儿的饭店吃饭，比如海底捞，为什么我们需要排队，是因为里面只能容纳这么多人吃饭，位置不够了，
我们就要去排队，有人吃完出来了才能有新的人进去，同样的道理
使用使用
下面还是常规流程 可能有的人没用过，就写个小demo,介绍下他的使用
先看下代码：
/**
* @ClassName SemaphoreDemo
* @Auther burgxun
* @Description: 使用信号量的Demo
* @Date 2020/4/3 13:53
**/
public class SemaphoreDemo {
public static void PrintLog(String logContent) {
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm.ss.SSS");
System.out.println(String.format("%s : %s", simpleDateFormat.format(new Date()), logContent));
}
public static void main(String[] args) throws InterruptedException {
Semaphore semaphore = new Semaphore(10);
Thread thread1 = new Thread(new Runnable() {
@Override
public void run() {
try {
PrintLog("Thread1 starting ......");
semaphore.acquire(5);
PrintLog("Thread1 get permits success");
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
PrintLog("thread1 release permits success");
semaphore.release(5);
}
}
});
Thread thread2 = new Thread(new Runnable() {
@Override
public void run() {
try {
PrintLog("Thread2 starting ......");
semaphore.acquire(5);
PrintLog("Thread2 get permits success");
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
PrintLog("thread2 release permits success");
semaphore.release(5);
}
}
});
thread1.start();
thread2.start();
try {
评论0