时间:2021-05-20
Java并发编程之Semaphore(信号量)详解及实例
概述
通常情况下,可能有多个线程同时访问数目很少的资源,如客户端建立了若干个线程同时访问同一数据库,这势必会造成服务端资源被耗尽的地步,那么怎样能够有效的来控制不可预知的接入量呢?及在同一时刻只能获得指定数目的数据库连接,在JDK1.5 java.util.concurrent 包中引入了Semaphore(信号量),信号量是在简单上锁的基础上实现的,相当于能令线程安全执行,并初始化为可用资源个数的计数器,通常用于限制可以访问某些资源(物理或逻辑的)的线程数目。例如我们可以将一个信号量初始化为可获得的数据库连接个数。一旦某个线程获得了信号量,可获得的数据库连接数减1。线程消耗完资源并释放该资源时,计数器就会加1。当信号量控制的所有资源都已被占用时,若有线程试图访问此信号量,则会进入阻塞状态,直到有可用资源被释放。简单理解就是:如去银行办理业务,只有6个窗口,所以可同时给6个客户办理业务,其他客户只能等待,当有其中一个窗口办理完业务时就会通知下一个客户办理。
主要方法
1、构造方法
Semaphore提供了一个带有boolean参数的构造方法,true代表公平锁,false代表非公平锁,默认实现是非公平锁
2、普通方法
3、 我们来模拟客户在银行办理业务的场景示例
import java.util.Random;import java.util.concurrent.Semaphore;public class BankService { public static void main(String[] args) { Runnable customer = new Runnable() { final Semaphore availableWindow = new Semaphore(5, true); int count = 1; @Override public void run() { int time = (int) (Math.random() * 10 + 3); int num = count++; try { availableWindow.acquire(); System.out.println("正在为第【" + num + "】个客户办理业务,需要时间:" + time + "s!"); Thread.sleep(time * 1000); if (availableWindow.hasQueuedThreads()) { System.out.println("第【" + num + "】个客户已办理完业务,有请下一位!"); } else { System.out.println("第【" + num + "】个客户已办理完业务,没有客户了,休息中!"); } availableWindow.release(); } catch (InterruptedException e) { e.printStackTrace(); } } }; for (int i = 1; i < 10; i++) { new Thread(customer).start(); } }}4、运行结果
感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
一、信号量(Semaphore)信号量(Semaphore)是由内核对象维护的int变量,当信号量为0时,在信号量上等待的线程会堵塞,信号量大于0时,就解除堵塞
Java通过代码模拟高并发可以以最快的方式发现我们系统中潜在的线程安全性问题,此处使用Semaphore(信号量)和CountDownLatch(闭锁)搭配Ex
Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解在java1.5中,提供了一些非常有用的辅助类来帮助我们
Semaphore是一个计数信号量,它的本质是一个共享锁。信号量维护了一个信号量许可集。线程可以通过调用acquire()来获取信号量的许可;当信号量中有可用的
互斥锁和信号量都是操作系统中为并发编程设计基本概念,互斥锁和信号量的概念上的不同在于,对于同一个资源,互斥锁只有0和1的概念,而信号量不止于此。也就是说,信号量