`

Semaphore的介绍和使用

阅读更多

一个计数信号量。从概念上讲,信号量维护了一个许可集。如有必要,在许可可用前会阻塞每一个 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释放出机器

 

 

1
1
分享到:
评论

相关推荐

    python线程信号量semaphore使用解析

    这篇文章主要介绍了python线程信号量semaphore使用解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 一.semaphore信号量原理 多线程同时运行,能提高程序的...

    Java中的Semaphore:深入理解与应用实践

    本文将详细介绍 Semaphore 的工作原理、使用方法以及如何在实际项目中应用它。 Semaphore 是Java并发编程中实现信号量机制的重要工具。它通过维护一个许可集来控制同时访问特定资源的线程数量,从而避免资源竞争和...

    Semaphore RTU SCADA SNMP.pdf

    1. 描述中提及的三个技术概念联合使用,表明本文可能讨论了在SCADA系统中通过SNMP协议对Semaphore RTU进行远程监控和诊断的技术实现和优势。 2. 文档可能是关于如何将SNMP协议集成到SCADA系统中,用于管理RTU设备。 ...

    Java中的Semaphore类最全讲义

    目录: 简介 1.1 并发编程与资源控制 ...3.2 使用Semaphore控制资源访问 实现有界资源池 4.1 场景介绍 4.2 使用Semaphore实现有界资源池 Semaphore的公平性 5.1 非公平性 5.2 公平性 最佳实践与注意事项

    04_FreeRTOS_Counting_Semaphore.rar

    使用CMSIS API ,介绍FreeRTOS中计数信号量 b. 不使用CMSIS API,直接使用FreeRTOS函数 1. 简介 计数信号量可用于控制对资源的访问。要获得对资源的控制,任务必须首先获得信号量。因此减少了信号量计数值。当计...

    CountDownLatch、Semaphore等4大并发工具类详解

    本文将详细介绍 Java 并发工具类的四大类:CountDownLatch、Semaphore、CyclicBarrier 和 Phaser,及其应用场景和使用方法。 CountDownLatch CountDownLatch 是一个同步的辅助类,允许一个或多个线程,等待其他一...

    freertos.rar_2440 FREERTOS_freertos_recursive semaphore_嵌入式

    在“freertos.rar_2440 FREERTOS_freertos_recursive_semaphore_嵌入式”这个压缩包中,我们主要探讨的是FreeRTOS在2440平台上的应用以及递归信号量的概念和使用。 2440平台通常指的是Samsung公司的S3C2440微处理器...

    Semaphore SCADA SECURITY UPDATE.pdf

    本文档作为一份安全更新资料,将详细介绍SCADA系统安全的最佳实践,并特别关注SCADA RTU(远程终端单元)的部署及其监控和控制过程。 在过去几年的有关SCADA系统安全的报告中,一个关键问题一直被反复提及:是否...

    Java并发编程之Semaphore(信号量)详解及实例

    下面,我们将详细介绍 Semaphore 的原理、实现和实例。 Semaphore 的原理 Semaphore 是一个计数器,用于限制可以访问某些资源的线程数目。当某个线程获得了信号量时,计数器就会减 1;当线程消耗完资源并释放该...

    信号量同步等待机制 semaphore wait-and-signal

    下面以生产者-消费者问题为例,介绍如何使用信号量实现互斥和同步。 ##### 生产者-消费者问题 生产者-消费者问题是多线程编程中的一个经典问题。该问题包含两个线程:生产者线程负责生成数据并放入队列或缓冲区中...

    docs:Semaphore 2.0文档

    Semaphore 2.0 的文档详细介绍了如何使用该服务来自动化软件开发流程,确保代码质量和快速迭代。本文将深入探讨Semaphore 2.0的关键特性、工作原理以及如何通过其提供的文档进行有效配置和使用。 ** Semaphore 2.0 ...

    java 多线程的详细介绍和使用

    总结来说,Java多线程和线程池的使用涉及到线程创建、同步、管理和优化等多个方面。掌握这些知识对于编写高效、可靠的并发程序至关重要。线程池作为一种高级的线程管理工具,通过复用线程和控制并发,极大地提升了...

    Semaphore_TBOX_产品-软件及系统功能

    通过以上介绍可以看出,Semaphore_TBOX产品不仅提供了强大的硬件支持,还配备了一整套完善的软件解决方案,旨在满足各种工业自动化场景的需求。无论是对于工程师还是最终用户而言,这些工具都能极大地提高工作效率和...

    little_book_of_semaphore,带目录完全版

    该书不仅介绍了信号量的基本用法,还通过一系列典型的同步问题,如读者-写者问题和生产者-消费者问题,向读者展示了信号量模式的复杂应用。 信号量是一种广泛用于进程同步和互斥的机制,由荷兰计算机科学家Edsger W...

    Java并发编程Semaphore计数信号量详解

    在本文中,我们将详细介绍Java并发编程Semaphore计数信号量的工作原理和应用。 一、Semaphore的概念 Semaphore是Java并发编程中的一种同步机制,它允许一定数量的线程访问某个资源。Semaphore的概念来自于操作系统...

    Java并发系列之Semaphore源码分析

    Java并发系列之Semaphore源码分析是Java并发系列中的一篇重要文章,主要为大家详细介绍了Java并发系列之Semaphore源码,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。 Semaphore(信号量)是JUC包中比较常...

    Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解

    本文将详细介绍这三个辅助类的用法和实例详解。 一、CountDownLatch用法 CountDownLatch类位于java.util.concurrent包下,利用它可以实现类似计数器的功能。它可以让一个线程等待其他线程执行完毕后再执行。...

    多线程的介绍和使用!

    Windows API提供了多种同步机制,如`Mutex`(互斥体)、`Semaphore`(信号量)、`Event`(事件对象)和`Critical Section`(临界区),用于控制对共享资源的访问。 ### 5. 使用C Run-time Library和MFC进行多线程...

    Python 限制线程的最大数量的方法(Semaphore)

    ### Python 限制线程最大数量的方法(Semaphore) 在多线程编程中,有时我们需要控制并发线程...在实际开发中,合理使用 `Semaphore` 可以帮助我们更好地管理和优化多线程程序。希望本篇内容能为你提供有价值的参考。

Global site tag (gtag.js) - Google Analytics