java信号量初始化为0_Java中Semaphore(信号量)的使用方法

喜欢ヅ旅行 2022-11-08 05:59 161阅读 0赞

public class ResourceManage \{

private final Semaphore semaphore ;

private boolean resourceArray\[\];

private final ReentrantLock lock;

public ResourceManage() \{

this.resourceArray = new boolean\[10\];//存放厕所状态

this.semaphore = new Semaphore(10,true);//控制10个共享资源的使用，使用先进先出的公平模式进行共享;公平模式的信号量，先来的先获得信号量

this.lock = new ReentrantLock(true);//公平模式的锁，先来的先选

for(int i=0 ;i<10; i++)\{

resourceArray\[i\] = true;//初始化为资源可用的情况

\}

\}

public void useResource(int userId)\{

semaphore.acquire();

try\{

//semaphore.acquire();

int id = getResourceId();//占到一个坑

System.out.print("userId:"+userId+"正在使用资源，资源id:"+id+"\\n");

Thread.sleep(100);//do something，相当于于使用资源

resourceArray\[id\] = true;//退出这个坑

\}catch (InterruptedException e)\{

e.printStackTrace();

\}finally \{

semaphore.release();//释放信号量，计数器加1

\}

\}

private int getResourceId()\{

int id = -1;

lock.lock();

try \{

//lock.lock();//虽然使用了锁控制同步，但由于只是简单的一个数组遍历，效率还是很高的，所以基本不影响性能。

for(int i=0; i<10; i++)\{

if(resourceArray\[i\])\{

resourceArray\[i\] = false;

id = i;

break;

\}

\}

\}catch (Exception e)\{

e.printStackTrace();

\}finally \{

lock.unlock();

\}

return id;

\}

\}

public class ResourceUser implements Runnable\{

private ResourceManage resourceManage;

private int userId;

public ResourceUser(ResourceManage resourceManage, int userId) \{

this.resourceManage = resourceManage;

this.userId = userId;

\}

public void run()\{

System.out.print("userId:"+userId+"准备使用资源...\\n");

resourceManage.useResource(userId);

System.out.print("userId:"+userId+"使用资源完毕...\\n");

\}

public static void main(String\[\] args)\{

ResourceManage resourceManage = new ResourceManage();

Thread\[\] threads = new Thread\[100\];

for (int i = 0; i < 100; i++) \{

Thread thread = new Thread(new ResourceUser(resourceManage,i));//创建多个资源使用者

threads\[i\] = thread;

\}

for(int i = 0; i < 100; i++)\{

Thread thread = threads\[i\];

try \{

thread.start();//启动线程

\}catch (Exception e)\{

e.printStackTrace();

\}

\}

\}

\}

发表评论取消回复

表情：

评论列表（有 0 条评论，161人围观）

还没有评论，来说两句吧...

相关阅读

相关信号量（Semaphore）

信号量（Semaphore）是一种经典的多线程同步工具，用于控制多个线程对共享资源的访问。信号量维护了一个计数器，表示可用的资源数量，线程可以通过信号量来请求资源并释放资源。信

浅浅的花香味﹌/ 2023年10月15日 17:03/ 0 赞/ 64 阅读

相关 Java中信号量Semaphore的使用

1. Semaphore的作用在java中，使用了synchronized关键字和Lock锁实现了资源的并发访问控制，在同一时间只允许唯一的线程进入临界区访问资源(读锁

青旅半醒/ 2023年01月07日 14:29/ 0 赞/ 184 阅读

相关 java信号量初始化为0_Java中Semaphore(信号量)的使用方法

public class ResourceManage \{ private final Semaphore semaphore ; private boolean res

喜欢ヅ旅行/ 2022年11月08日 05:59/ 0 赞/ 162 阅读

相关 Java并发 - Semaphore（信号量）

应用场景：多个共享资源互斥、并发限流（如Hystrix）。信号量是操作系统中，实现进程间资源的互斥与同步。信号量维护了一组许可证，以约束访问被限制资源的线程数。 Java

蔚落/ 2022年09月07日 05:49/ 0 赞/ 238 阅读

相关 Java 信号量 Semaphore 介绍

转：[http://www.cnblogs.com/whgw/archive/2011/09/29/2195555.html][http_www.cnblogs.com_whg

╰半橙微兮°/ 2022年05月23日 13:35/ 0 赞/ 261 阅读

相关 Java中的信号量Semaphore

（转自：[https://blog.csdn.net/zlp1992/article/details/52703793][https_blog.csdn.net_zlp1992

àì夳堔傛蜴生んèń/ 2022年05月23日 04:47/ 0 赞/ 210 阅读

相关 Semaphore信号量

当我们需要控制最多多少个线程同时执行时，我们需要信号量。 Semaphore semaphore = new Semaphore(5);//配置最多5个线程同时执行

小鱼儿/ 2022年05月22日 22:22/ 0 赞/ 305 阅读

相关 JAVA并发信号量 Semaphore

\[b\]\[color=green\]\[size=medium\]Semaphore当前在多线程环境下被扩放使用，操作系统的信号量是个很重要的概念，在进程控制方面都有应用。

淩亂°似流年/ 2022年04月21日 15:10/ 0 赞/ 302 阅读

相关信号量 Semaphore

信号量 Semaphore 1. 简介信号量 Semaphore 是一个控制访问多个共享资源的计数器，和 CountDownLatch 一样，其本质上是一个“共享

小鱼儿/ 2022年01月26日 13:37/ 0 赞/ 409 阅读

相关信号量(Semaphore)

我们从以下几点学习信号量 1、信号量的作用，信号量是用来做什么的？它维护了一个许可集，我们在初始化时需要传一个许可集数量，该数量值代表同一时间能访问共享资源的线程

傷城~/ 2021年09月21日 15:34/ 0 赞/ 535 阅读