一个计数信号量。从概念上讲,信号量维护了一个许可集。如有必要,在许可可用前会阻塞每一个 acquire(),然后再获取该许可。每个 release() 添加一个许可,从而可能释放一个正在阻塞的获取者。但是,不使用实际的许可对象,Semaphore 只对可用许可的号码进行计数,并采取相应的行动。拿到信号量的线程可以进入代码,否则就等待。通过acquire()和release()获取和释放访问许可。
Semaphore类位于java.util.concurrent包下,它提供了2个构造器:
//参数permits表示许可数目,即同时可以允许多少线程进行访问 public Semaphore(int permits) { sync = new NonfairSync(permits); } //这个多了一个参数fair表示是否是公平的,即等待时间越久的越先获取许可 public Semaphore(int permits, boolean fair) { sync = (fair)? new FairSync(permits) : new NonfairSync(permits); }
Semaphore类中比较重要的几个方法,首先是acquire()、release()方法:
acquire()用来获取一个许可,若无许可能够获得,则会一直等待,直到获得许可。
release()用来释放许可。注意,在释放许可之前,必须先获获得许可。
public void acquire() throws InterruptedException { } //获取一个许可 public void acquire(int permits) throws InterruptedException { } //获取permits个许可 public void release() { } //释放一个许可 public void release(int permits) { } //释放permits个许可
这4个方法都会被阻塞,如果想立即得到执行结果,可以使用下面几个方法:
//尝试获取一个许可,若获取成功,则立即返回true,若获取失败,则立即返回false public boolean tryAcquire() { }; //尝试获取一个许可,若在指定的时间内获取成功,则立即返回true,否则则立即返回false public boolean tryAcquire(long timeout, TimeUnit unit) throws InterruptedException { }; //尝试获取permits个许可,若获取成功,则立即返回true,若获取失败,则立即返回false public boolean tryAcquire(int permits) { }; //尝试获取permits个许可,若在指定的时间内获取成功,则立即返回true public boolean tryAcquire(int permits, long timeout, TimeUnit unit) throws InterruptedException { }; //得到当前可用的许可数目 public int availablePermits();
假若一个工厂有5台机器,但是有8个工人,一台机器同时只能被一个工人使用,只有使用完了,其他工人才能继续使用。那么我们就可以通过Semaphore来实现:
public class Test { public static void main(String[] args) { int N = 8; //工人数 Semaphore semaphore = new Semaphore(5); //机器数目 for(int i=0;i<N;i++) new Worker(i,semaphore).start(); } static class Worker extends Thread{ private int num; private Semaphore semaphore; public Worker(int num,Semaphore semaphore){ this.num = num; this.semaphore = semaphore; } @Override public void run() { try { semaphore.acquire(); System.out.println("工人"+this.num+"占用一个机器在生产..."); Thread.sleep(2000); System.out.println("工人"+this.num+"释放出机器"); semaphore.release(); } catch (InterruptedException e) { e.printStackTrace(); } } } }
运行结果:
工人0占用一个机器在生产... 工人1占用一个机器在生产... 工人2占用一个机器在生产... 工人4占用一个机器在生产... 工人5占用一个机器在生产... 工人0释放出机器 工人2释放出机器 工人3占用一个机器在生产... 工人7占用一个机器在生产... 工人4释放出机器 工人5释放出机器 工人1释放出机器 工人6占用一个机器在生产... 工人3释放出机器 工人7释放出机器 工人6释放出机器
相关推荐
这篇文章主要介绍了python线程信号量semaphore使用解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.semaphore信号量原理 多线程同时运行,能提高程序的...
本文将详细介绍 Semaphore 的工作原理、使用方法以及如何在实际项目中应用它。 Semaphore 是Java并发编程中实现信号量机制的重要工具。它通过维护一个许可集来控制同时访问特定资源的线程数量,从而避免资源竞争和...
1. 描述中提及的三个技术概念联合使用,表明本文可能讨论了在SCADA系统中通过SNMP协议对Semaphore RTU进行远程监控和诊断的技术实现和优势。 2. 文档可能是关于如何将SNMP协议集成到SCADA系统中,用于管理RTU设备。 ...
目录: 简介 1.1 并发编程与资源控制 ...3.2 使用Semaphore控制资源访问 实现有界资源池 4.1 场景介绍 4.2 使用Semaphore实现有界资源池 Semaphore的公平性 5.1 非公平性 5.2 公平性 最佳实践与注意事项
使用CMSIS API ,介绍FreeRTOS中计数信号量 b. 不使用CMSIS API,直接使用FreeRTOS函数 1. 简介 计数信号量可用于控制对资源的访问。要获得对资源的控制,任务必须首先获得信号量。因此减少了信号量计数值。当计...
本文将详细介绍 Java 并发工具类的四大类:CountDownLatch、Semaphore、CyclicBarrier 和 Phaser,及其应用场景和使用方法。 CountDownLatch CountDownLatch 是一个同步的辅助类,允许一个或多个线程,等待其他一...
在“freertos.rar_2440 FREERTOS_freertos_recursive_semaphore_嵌入式”这个压缩包中,我们主要探讨的是FreeRTOS在2440平台上的应用以及递归信号量的概念和使用。 2440平台通常指的是Samsung公司的S3C2440微处理器...
本文档作为一份安全更新资料,将详细介绍SCADA系统安全的最佳实践,并特别关注SCADA RTU(远程终端单元)的部署及其监控和控制过程。 在过去几年的有关SCADA系统安全的报告中,一个关键问题一直被反复提及:是否...
下面,我们将详细介绍 Semaphore 的原理、实现和实例。 Semaphore 的原理 Semaphore 是一个计数器,用于限制可以访问某些资源的线程数目。当某个线程获得了信号量时,计数器就会减 1;当线程消耗完资源并释放该...
下面以生产者-消费者问题为例,介绍如何使用信号量实现互斥和同步。 ##### 生产者-消费者问题 生产者-消费者问题是多线程编程中的一个经典问题。该问题包含两个线程:生产者线程负责生成数据并放入队列或缓冲区中...
Semaphore 2.0 的文档详细介绍了如何使用该服务来自动化软件开发流程,确保代码质量和快速迭代。本文将深入探讨Semaphore 2.0的关键特性、工作原理以及如何通过其提供的文档进行有效配置和使用。 ** Semaphore 2.0 ...
总结来说,Java多线程和线程池的使用涉及到线程创建、同步、管理和优化等多个方面。掌握这些知识对于编写高效、可靠的并发程序至关重要。线程池作为一种高级的线程管理工具,通过复用线程和控制并发,极大地提升了...
通过以上介绍可以看出,Semaphore_TBOX产品不仅提供了强大的硬件支持,还配备了一整套完善的软件解决方案,旨在满足各种工业自动化场景的需求。无论是对于工程师还是最终用户而言,这些工具都能极大地提高工作效率和...
该书不仅介绍了信号量的基本用法,还通过一系列典型的同步问题,如读者-写者问题和生产者-消费者问题,向读者展示了信号量模式的复杂应用。 信号量是一种广泛用于进程同步和互斥的机制,由荷兰计算机科学家Edsger W...
在本文中,我们将详细介绍Java并发编程Semaphore计数信号量的工作原理和应用。 一、Semaphore的概念 Semaphore是Java并发编程中的一种同步机制,它允许一定数量的线程访问某个资源。Semaphore的概念来自于操作系统...
Java并发系列之Semaphore源码分析是Java并发系列中的一篇重要文章,主要为大家详细介绍了Java并发系列之Semaphore源码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。 Semaphore(信号量)是JUC包中比较常...
本文将详细介绍这三个辅助类的用法和实例详解。 一、CountDownLatch用法 CountDownLatch类位于java.util.concurrent包下,利用它可以实现类似计数器的功能。它可以让一个线程等待其他线程执行完毕后再执行。...
Windows API提供了多种同步机制,如`Mutex`(互斥体)、`Semaphore`(信号量)、`Event`(事件对象)和`Critical Section`(临界区),用于控制对共享资源的访问。 ### 5. 使用C Run-time Library和MFC进行多线程...
### Python 限制线程最大数量的方法(Semaphore) 在多线程编程中,有时我们需要控制并发线程...在实际开发中,合理使用 `Semaphore` 可以帮助我们更好地管理和优化多线程程序。希望本篇内容能为你提供有价值的参考。