信号量(java并发编程实战5.5.4)

以你之姓@ 2022-07-12 04:38 172阅读 0赞

用途：用来控制同时访问某个特定资源的操作数量，或者同时执行某个指定操作的数量。计数信号量可以用来实现某种资源池，或者对容器施加边界。

public class SemaphoreTest<T> {
    	private final Set<T> set;
    	
    	private final Semaphore sema;
    	
    	public SemaphoreTest(int bound){
    		this.set = Collections.synchronizedSet(new HashSet<T>());
    		this.sema = new Semaphore(bound);
    	}
    	
    	public boolean add(T o) throws InterruptedException{
    		sema.acquire();
    		boolean wasAdded = false;
    		try{
    			wasAdded = set.add(o);
    			return wasAdded;
    		}finally{
    			if(!wasAdded){
    				sema.release();
    			}
    		}
    	}
    	
    	public boolean remove(T o){
    		boolean wasRemoved = set.remove(o);
    		if(wasRemoved){
    			sema.release();
    		}
    		return wasRemoved;
    	}
    	
    	public static void main(String[] args) throws InterruptedException{
    		int permits = 5;
    		int elements = permits + 1;
    		SemaphoreTest<Integer> test = new SemaphoreTest<Integer>(permits);
    		for(int i = 0;i < elements; i++){
    			test.add(i);
    		}
    	}
    }

由于实际待添加的元素个数大于信号量所允许的数量，因此最后一次添加时，会一直阻塞。

发表评论取消回复

表情：

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

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

相关阅读

相关 Java并发编程：Semaphore信号量示例

在Java并发编程中，Semaphore（信号量）是一种同步工具，它管理对某个共享资源的访问。以下是一个简单的Semaphore信号量示例： ```java import

你的名字/ 2024年12月06日 07:33/ 0 赞/ 26 阅读

相关 Java并发编程：锁和信号量示例

在Java并发编程中，锁（Lock）和信号量（Semaphore）都是用于线程同步的工具。 1. 锁（Lock）示例： ```java import java.util.co

- 日理万妓/ 2024年11月15日 11:39/ 0 赞/ 46 阅读

相关实战案例：Java并发编程中信号量的使用

在Java并发编程中，信号量（Semaphore）是一种同步原语，用于控制对共享资源的访问。它类似于一个计数器，但是它的值可以为负。下面是一个简单的实战案例，展示了如何使用

蔚落/ 2024年10月08日 15:03/ 0 赞/ 61 阅读

相关 Java并发编程实战：锁、信号量与条件变量应用示例

在Java并发编程中，锁（Lock）、信号量（Semaphore）和条件变量（Condition Variable）是重要的工具。这里我将为你展示它们的应用示例。 1. 锁（

谁借莪１个温暖的怀抱￠/ 2024年09月29日 08:42/ 0 赞/ 97 阅读

相关 Java并发编程：信号量（Semaphore）示例分析

在Java的并发编程中，信号量(Semaphore)是一种用于管理共享资源的机制。它类似于锁，但是可以控制同时访问资源的数量。以下是一个简单的信号量示例： ```java

秒速五厘米/ 2024年09月17日 01:06/ 0 赞/ 77 阅读

相关信号量(java并发编程实战5.5.4)

用途：用来控制同时访问某个特定资源的操作数量，或者同时执行某个指定操作的数量。计数信号量可以用来实现某种资源池，或者对容器施加边界。 public class

以你之姓@/ 2022年07月12日 04:38/ 0 赞/ 173 阅读

相关并发编程--Semaphore计数信号量

Semaphore是一个计数信号量，它的本质是一个共享锁。信号量维护了一个信号量许可集。线程可以通过调用acquire()来获取信号量的许可；当信号量中有可用的许可时，线程能获

我就是我/ 2022年06月17日 05:22/ 0 赞/ 267 阅读

相关 java并发编程——临界区，互斥量，信号量

四种进程或线程同步互斥的控制方法 1、临界区:通过对多线程的串行化来访问公共资源或一段代码，速度快，适合控制数据访问。 2、互斥量:为协调共同对一个共享资源的单独访问

柔光的暖阳◎/ 2022年05月15日 06:40/ 0 赞/ 336 阅读

相关 JAVA并发信号量 Semaphore

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

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

相关 Java 信号量实战

一点睛它的作用是限流，可以允许多个线程同时执行。二代码 import java.util.concurrent.Semaphore;

青旅半醒/ 2021年07月24日 22:17/ 0 赞/ 412 阅读