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

以你之姓@ 2022-07-12 04:38 156阅读 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 条评论，156人围观）

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

相关阅读

相关 Java并发编程基础：锁和信号量概述

在Java并发编程中，锁和信号量是两种重要的同步工具。它们分别对应于操作系统中的硬件资源管理和多线程环境下的互斥控制。 1. 锁： - 同步原语：synchronized关键

旧城等待，/ 2024年09月23日 00:01/ 0 赞/ 51 阅读

相关【Java并发编程】synchronized（四）：信号量、互斥量原理分析对比

1.信号量信号量是用来协调不同进程间的数据对象的，而最主要的应用是共享内存方式的进程间通信。本质上，信号量是一个计数器，它用来记录对某个资源（如共享内存）的存取状况。

ゝ一世哀愁。/ 2022年12月08日 01:38/ 0 赞/ 196 阅读

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

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

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

相关 JAVA并发信号量 Semaphore

转载自http://qindongliang.iteye.com/blog/2017276 Semaphore当前在多线程环境下被扩放使用，操作系统的信号量是个很重

分手后的思念是犯贱/ 2022年08月08日 05:18/ 0 赞/ 250 阅读

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

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

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

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

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

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

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

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

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

相关 JAVA并发信号量 Semaphore

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

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

相关 Java并发编程实战：闭锁CountDownLatch，栅栏CyclicBarrier与信号量Semaphore

整体上对三个概念进行一个说明： CountDownLatch和CyclicBarrier都能够实现线程之间的等待，只不过它们侧重点不同： CountDownLatch

àì夳堔傛蜴生んèń/ 2022年04月17日 04:49/ 0 赞/ 285 阅读

相关 Java 信号量实战

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

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