Semaphore(信号量),通常用来限制可以访问资源的线程数量,使他们能够正确、合理地使用公共资源。比如1个餐厅最多可容纳10人就餐,多余的人就需要等位。
Semaphore的acquire方法用来获取一个资源的许可,release方法用来释放一个资源的许可。
/** * Semaphore demo:一个餐厅同时可容纳10人吃饭,多余的人将会排队等候 * * @author usr1999 2015-1-18 */ public class SemaphoreDemo { public static void main(String[] args) { for (int i = 0; i < 30; i++) { Guest guest = new Guest(); Thread run = new Thread(guest); run.start(); } } } /** * 餐厅 */ class Restaurant { // 信号量为共享资源的属性 private static Semaphore semp = new Semaphore(10); // 只容纳10个人就餐 public static void eat() { try { semp.acquire(); System.out.println(Thread.currentThread().getName() + " is eating in restaurant"); Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } finally { System.out.println("1 thread release"); semp.release(); // 释放一个许可 } } } /** * 客人 */ class Guest implements Runnable { @Override public void run() { Restaurant.eat(); } }
demo program 2:
import java.util.ArrayList; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Semaphore; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /** * Java 5.0里新加了4个协调线程间进程的同步装置,它们分别是: * Semaphore, CountDownLatch, CyclicBarrier和Exchanger. * 本例主要介绍Semaphore。 * Semaphore是用来管理一个资源池的工具,可以看成是个通行证, * 线程要想从资源池拿到资源必须先拿到通行证, * 如果线程暂时拿不到通行证,线程就会被阻断进入等待状态。 */ public class SemaphoreTest { /** * 模拟资源池的类 * 只为池发放2个通行证,即同时只允许2个线程获得池中的资源。 */ public static class Pool { // 保存资源池中的资源 ArrayList<String> pool = null; // 通行证 Semaphore pass = null; Lock lock = new ReentrantLock(); public Pool(int size) { // 初始化资源池 pool = new ArrayList<String>(); for (int i = 0; i < size; i++) { pool.add("Resource " + i); } // 发放2个通行证 pass = new Semaphore(2); } public String get() throws InterruptedException { // 获取通行证,只有得到通行证后才能得到资源 System.out.println("Try to get a pass..."); pass.acquire(); System.out.println("Got a pass"); return getResource(); } public void put(String resource) { // 归还通行证,并归还资源 System.out.println("Released a pass"); pass.release(); releaseResource(resource); } private String getResource() { lock.lock(); String result = pool.remove(0); System.out.println("资源 " + result + " 被取走"); lock.unlock(); return result; } private void releaseResource(String resource) { lock.lock(); System.out.println("资源 " + resource + " 被归还"); pool.add(resource); lock.unlock(); } } public static void testPool() { // 准备10个资源的资源池 final Pool aPool = new Pool(10); Runnable worker = new Runnable() { public void run() { String resource = null; try { //取得resource resource = aPool.get(); //用resource做工作 System.out.println("I am working on " + resource); Thread.sleep(500); System.out.println("I finished on " + resource); } catch (InterruptedException ex) { } //归还resource aPool.put(resource); } }; // 启动5个任务 ExecutorService service = Executors.newCachedThreadPool(); for (int i = 0; i < 5; i++) { service.submit(worker); } service.shutdown(); } public static void main(String[] args) { SemaphoreTest.testPool(); } }
相关推荐
Semaphore的使用及其方法的使用。
semaphore完整搭建方案,包括帮助文档、程序源码、可执行程序。按照帮助文档完整搭建可视化ansible部署解决方案
这篇文章主要介绍了python线程信号量semaphore使用解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.semaphore信号量原理 多线程同时运行,能提高程序的...
自己用Semaphore制作的最简单的,1生产者,1消费者,多缓冲区的模型...于VC下通过..
关于Android变成中的信号量semaphore,在使用过程中我们往往搞不清楚其信号量的申请和使用。这里主要针对信号量初始值为零的情况做介绍,其他情况不做讨论。初始值为零的情况较少使用,部分代码中的这个情况往往让...
Python3高级核心技术97讲-进程和- Semaphore 使用以.mp4
Semaphore:可理解为允许线程执行信号的池子,池子中放入多少个信号就允许多少线程同时执行。 private static void MultiThreadSynergicWithSemaphore() { //0表示创建Semaphore时,拥有可用信号量数值 //1表示...
使用信号量(Semaphore)实现线程的同步
Linux下多线程编程-Pthread与Semaphore的使用.doc
semaphore开发源码,ansible可视化部署服务程序,支持界面操作。
Semaphore 源码解析 通过使用Semaphore可以在高并发场景进行限流控制处理
Semaphore T-BOX System OverviewPDF,Semaphore T-BOX System Overview
mutex和semaphore互斥程序实例
Semaphore是计数信号量。Semaphore管理一系列许可证。每个acquire方法阻塞,直到有一个许可证可以获得然后拿走一个许可证;每个release方法增加一个许可证,这可能会释放一个阻塞的acquire方法。然而,其实并没有...
C#语言Semaphore类用法实例,多线程 用于有多个同类型共享资源(比如端口)时,如何协调端口分配给线程访问资源的问题,是一个简单模拟实例(源代码)。
Football_using_semaphore 使用信号量和共享内存模拟足球比赛
Semaphore的初步使用 Semaphore是什么,能做什么? Semaphore 是 synchronized 的加强版,作用是控制线程的并发数量。就这一点而言,单纯的synchronized 关键字是实现不了的。 直接看例子吧,这个例子包含3个类,一...
semaphore控制多线程循序执行,网上 找的例子更改的希望对大家有用
Semaphore_TBOX_产品-软件及系统功能