Semaphore可以维护当前访问自身的线程个数,并提供了同步机制,使用Semaphore可以控制同时访问资源的线程数,例如,实现一个文件允许的并发访问数.
Semaphore实现的功能就类似厕所一共有5个茅坑(new Semaphore(5)),加入有10个人(10个线程)要上厕所,那么同时只能有5个人能够占用,当占用的5个人任何一个让开后(release()方法),其中等待的另外5个人中又有一个可以占用了(acquire()方法).
另外等待的5个人可以是随机获取优先机会,也可以是按照先来后到的顺序获取机会,这取决于构造方法传入的参数选项.public Semaphore(int permits, boolean fair)
单个信号量的Semaphore对象可以实现互斥锁的功能,并且可以是由一个线程获得锁,再由另外一个线程释放锁,也就是一个线程可以去释放锁,尽管他没有得到permit,这可以应用死锁恢复的一些场合.
public class SemaphoreTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final Semaphore sp = new Semaphore(3,true);
for (int i = 0; i < 10; i++) {
Runnable runnable = new Runnable() {
public void run() {
try {
sp.acquire();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "进入,当前已有" + (3 - sp.availablePermits()) + "个并发");
try {
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "即将离开");
sp.release();
// 下面代码有时候执行不准确,因为其没有和上面的代码合成原子单元
System.out.println("线程" + Thread.currentThread().getName()
+ "已离开,当前已有" + (3 - sp.availablePermits()) + "个并发");
}
};
service.execute(runnable);
}
}
转载请注明出处:http://blog.csdn.net/johnny901114/article/details/8695717
分享到:
相关推荐
JAVA多线程--信号量(Semaphore)_.docx
Linux下多线程编程-Pthread与Semaphore的使用.doc
Swift-dispatch_semaphore
OC-dispatch_semaphore
Laravel开发-laravel-semaphore 信号量集成到Laravel的通知层。
使用信号量(Semaphore)实现线程的同步
多线程(C++)同步Semaphore
开源项目-vasilmkd-semaphore.zip,A lockless semaphore package using atomic instructions, feedback appreciated
bt信号量 一个受SBCL信号量启发的波尔多线程的简单信号量类。 过时的! 从0.8.6版本开始,bordeaux-threads有其自己的内置信号量,因此您绝对应该使用它代替bt-...semaphore-count返回semaphore-count的当前计数
1、信号量:就是一种可用来控制访问资源的数量的标识,设定了一个信 2、信号量主要有3个函数,分别是: 3、那么就开头提的问题,我们用代码来解决
主要介绍了JAVA 多线程之信号量(Semaphore)实例详解的相关资料,需要的朋友可以参考下
SimpleFork提供一套类似于JAVA多线程的进程控制接口,提供回收、同步、互斥、通信等方案,开发者可以关注业务问题,不需要过多考虑进程控制。 引入 composer require jenner/simple_fork require path/to/...
Java多线程Semaphore工具的使用详解.rar
环境 keil-mdk:5.27 STM32cubemx:6.6.1 HAL库:1.27.1 MCU:STM32F429IGT6 信号量demo
STM32F103+Azure threadx RTOS 信号量的使用 此程序包含Azure threadx RTOS代码在STM32F103芯片的移植,采用Keil5搭建工程。简单实现两个任务,一个任务发送信号,一个任务读取信号。
当前版本包括以下变量: 名称默认值描述semaphore_user_name 信号运行信号量服务的用户名semaphore_group_name 信号运行信号量服务的组名semaphore_user_uid 1000 Semaphore 服务用户的 UID semaphore_group_gid ...
Semaphore是计数信号量。Semaphore管理一系列许可证。每个acquire方法阻塞,直到有一个许可证可以获得然后拿走一个许可证;每个release方法增加一个许可证,这可能会释放一个阻塞的acquire方法。然而,其实并没有...
semaphore控制多线程循序执行,网上 找的例子更改的希望对大家有用
Delphi多线程之Semaphore_(信号对象).pdf