package com.supr;
import java.util.concurrent.Semaphore;
public class Four {
public static void main(String[] args) {
final Semaphore s = new Semaphore(3);
for (int i = 0; i < 20; i++) {
Thread t = new Thread(new Runnable() {
@Override
public void run() {
try {
s.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "获取到凭证开始执行..");
System.out.println("当前有"+(3-s.availablePermits())+"个线程并发...");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "凭证执行完毕，释放凭证..");
s.release();
}
});
t.start();
}
}
}
Thread-0获取到凭证开始执行.. 当前有1个线程并发... Thread-1获取到凭证开始执行.. 当前有2个线程并发... Thread-2获取到凭证开始执行.. 当前有3个线程并发... Thread-0凭证执行完毕，释放凭证.. Thread-3获取到凭证开始执行.. 当前有3个线程并发... Thread-1凭证执行完毕，释放凭证.. Thread-4获取到凭证开始执行.. 当前有3个线程并发... Thread-2凭证执行完毕，释放凭证.. Thread-5获取到凭证开始执行.. 当前有3个线程并发... Thread-3凭证执行完毕，释放凭证.. Thread-6获取到凭证开始执行.. 当前有3个线程并发... Thread-4凭证执行完毕，释放凭证.. Thread-7获取到凭证开始执行.. 当前有3个线程并发... Thread-5凭证执行完毕，释放凭证.. Thread-8获取到凭证开始执行.. 当前有3个线程并发... Thread-6凭证执行完毕，释放凭证.. Thread-9获取到凭证开始执行.. 当前有3个线程并发... Thread-7凭证执行完毕，释放凭证.. Thread-10获取到凭证开始执行.. Thread-8凭证执行完毕，释放凭证.. 当前有3个线程并发... Thread-11获取到凭证开始执行.. 当前有3个线程并发... Thread-9凭证执行完毕，释放凭证.. Thread-12获取到凭证开始执行.. 当前有3个线程并发... Thread-10凭证执行完毕，释放凭证.. Thread-13获取到凭证开始执行.. 当前有3个线程并发... Thread-11凭证执行完毕，释放凭证.. Thread-14获取到凭证开始执行.. 当前有3个线程并发... Thread-12凭证执行完毕，释放凭证.. Thread-15获取到凭证开始执行.. 当前有3个线程并发... Thread-13凭证执行完毕，释放凭证.. Thread-16获取到凭证开始执行.. 当前有3个线程并发... Thread-14凭证执行完毕，释放凭证.. Thread-17获取到凭证开始执行.. 当前有3个线程并发... Thread-15凭证执行完毕，释放凭证.. Thread-18获取到凭证开始执行.. 当前有3个线程并发... Thread-16凭证执行完毕，释放凭证.. Thread-17凭证执行完毕，释放凭证.. Thread-19获取到凭证开始执行.. 当前有2个线程并发... Thread-18凭证执行完毕，释放凭证.. Thread-19凭证执行完毕，释放凭证..
Semaphore:一个计数信号量。从概念上讲，信号量维护了一个许可集。如有必要，在许可可用前会阻塞每一个 acquire()，然后再获取该许可。每个 release() 添加一个许可，从而可能释放一个正在阻塞的获取者。
Semaphore 通常用于限制可以访问某些资源（物理或逻辑的）的线程数目。
说白了，Semaphore是一个计数器，在计数器不为0的时候对线程就放行，一旦达到0，那么所有请求资源的新线程都会被阻塞，包括增加请求到许可的线 程，也就是说Semaphore不是可重入的。每一次请求一个许可都会导致计数器减少1，同样每次释放一个许可都会导致计数器增加1，一旦达到了0，新的 许可请求线程将被挂起。
参考：http://www.blogjava.net/xylz/archive/2010/07/13/326021.html
http://blog.csdn.net/java2000_net/article/details/3997449
http://blog.163.com/maravilla_evol/blog/static/1395646992011912113635724/
http://blog.163.com/liu_sheng_han/blog/static/19059137220128240150242/
相关推荐
Semaphore 是一个强大的自动化部署工具，它使用 Ansible 来实现对多主机的配置管理。Ansible 是一个流行的 IT 自动化框架，它允许管理员通过编写 YAML 格式的 Playbook 来执行任务，如软件部署、配置管理和应用生命...
Semaphore的使用及其方法的使用。
在iOS开发中，理解并熟练使用`DispatchSemaphore`对于优化代码性能和处理同步问题至关重要。本文将深入探讨`DispatchSemaphore`的原理、用法以及在实际开发中的应用场景。 `DispatchSemaphore`是一种信号量机制，它...
这篇文章主要介绍了python线程信号量semaphore使用解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.semaphore信号量原理 多线程同时运行，能提高程序的...
自己用Semaphore制作的最简单的，1生产者，1消费者，多缓冲区的模型...于VC下通过..
使用 Semaphore 的好处包括提高效率、减少手动错误、简化团队协作，并且由于其开源性质，可以根据具体需求进行定制。对于那些想要尝试 Ansible 自动化但又不希望投入大量资源在 Tower 上的组织来说，Semaphore 是一...
Linux 下多线程编程-Pthread 与 Semaphore 的使用 Linux 下的多线程编程是通过使用 POSIX 线程接口，称为 pthread 实现的。要编写 Linux 下的多线程程序，需要使用头文件 pthread.h，连接时需要使用库 libpthread.a...
Python3高级核心技术97讲-进程和- Semaphore 使用以.mp4
2. **数据库交互**：Semaphore需要与数据库进行交互以存储项目配置、构建历史等数据，可能使用的是常见的关系型数据库如MySQL或非关系型数据库如MongoDB。 3. **API接口**：为了支持与其他工具的集成，Semaphore可能...
Semaphore：可理解为允许线程执行信号的池子，池子中放入多少个信号就允许多少线程同时执行。 private static void MultiThreadSynergicWithSemaphore() { //0表示创建Semaphore时，拥有可用信号量数值 //1表示...
在Java中，可以使用`java.util.concurrent.Semaphore`类，其使用方式与Python类似。 信号量是解决线程同步问题的一种高效工具，通过合理的信号量控制，可以有效地避免死锁、饥饿等问题，提高系统资源的利用率。理解...
本示例中，我们将深入探讨如何使用Semaphore来控制多线程的循序执行。 Semaphore是一种计数信号量，它可以有正整数值，用于管理多个线程对公共资源的访问。当信号量的值为正时，线程可以获取一个许可（或称资源），...
4. 为了确保资源的正确释放，推荐在`using`语句或`try...finally`块中使用Semaphore。这样即使发生异常，也能确保许可证最终被释放。 以下是一个简单的示例代码结构： ```csharp Semaphore semaphore = new ...
redis-semaphore使用 Redis 和简洁的 BLPOP 命令实现互斥和信号量。互斥锁和信号量是阻塞的，而不是轮询的，并且有一个公平的队列，按照先到先得的原则为进程提供服务。它还可以有一个可选的超时时间，超过该时间后...
下面是一个简单的Java Semaphore使用示例，模拟了一个只有两个车位的停车场： ```java import java.util.concurrent.Semaphore; public class ParkingLot { private Semaphore semaphore = new Semaphore(2); ...
例如，CWinThread可能在它的消息循环中使用WaitForSingleObjectEx来同步对Semaphore的访问，而CSyncObject则可以用来包装Semaphore对象，方便在MFC对象中使用。 这个测试源码很可能包含了如何创建、打开、使用和...
2.Semaphore使用实验 3.Runqueue长度观测实验 4.进程切换次数观测实验 5.RR调度算法定制实验 6.系统调用实验/设备驱动实验 7.进程地址空间布局实验 8.进程页表修改实验 实验平台 使用Virtual Box 导入学在...
在构造Semaphore时，可以通过传入布尔值决定使用哪种类型的锁。 在Semaphore中，`acquire()`方法用于获取一个许可，如果当前许可数足够，线程将获得同步状态并减少许可数，否则线程将被放入同步队列等待。`release...