【信号量】:
- 用于控制对某资源访问的同一时间的并发量。
【如何获取】:
- semaphore.tryAcquire(),尝试获取,不阻塞
- semaphore.acquire(),没信号量可用时,将进行阻塞等
【如何释放】:
- semaphore.release();
- 线程抛出各种异常,都别忘了在finally中释放信号量;
- 如果释放的比获取的信号量还多,例如获取了2个,释放了5次,那么当前信号量就动态的增加为5了,要注意。
【动态增加】:
- 多释放几次,就可以达到信号量动态增加的效果了
【动态减小】:
- 信号量本来有这个api的,不过是protected方法,所以我们需要显式继续Semaphore,并重新实现该api,见ResizeableSemaphore类中的reducePermits(int reduction);
- 举例如下:(该表格有个假设前提,不存在多余的release而产生出新的信号量,即release次数<=acquire次数)
当前信号量A (A=A1+A2) |
占用信号量A1 | 可用信号量A2 | 重新设置信号量B (B=B1+B2) |
当前可用的信号量B1 | 当前待释放的量B2 |
5 | 3 | 2 | 3 | 0 | 0 |
5 | 3 | 2 | 1 | 0 | -2 |
5 | 3 | 2 | 9 | 6 | 0 |
package com.jd.las.basic.service; import java.util.concurrent.Semaphore; /** * * Title: 动态信号量<br> * * Description: <br> * * Company: <a href=www.jd.com>京东</a><br> * * @author <a href=mailto:longzhun@jd.com>龙准</a> * * @date 2015年5月26日 下午7:29:42 */ public class JdSemaphore { /** * semaphore starts at 0 capacity; must be set by setMaxPermits before use */ private final ResizeableSemaphore semaphore = new ResizeableSemaphore(); /** * how many permits are allowed as governed by this semaphore. * Access must be synchronized on this object. */ private int maxPermits = 0; /** * New instances should be configured with setMaxPermits(). */ public JdSemaphore() { // no op } /* * Must be synchronized because the underlying int is not thread safe */ /** * Set the max number of permits. Must be greater than zero. * * Note that if there are more than the new max number of permits currently * outstanding, any currently blocking threads or any new threads that start * to block after the call will wait until enough permits have been released to * have the number of outstanding permits fall below the new maximum. In * other words, it does what you probably think it should. * * @param newMax */ public synchronized void setMaxPermits(int newMax) { if (newMax < 1) { throw new IllegalArgumentException("Semaphore size must be at least 1," + " was " + newMax); } int delta = newMax - this.maxPermits; if (delta == 0) { return; } else if (delta > 0) { // new max is higher, so release that many permits this.semaphore.release(delta); } else { delta *= -1; // delta < 0. // reducePermits needs a positive #, though. this.semaphore.reducePermits(delta); } this.maxPermits = newMax; } /** * Release a permit back to the semaphore. Make sure not to double-release. * */ public void release() { this.semaphore.release(); } /** * Get a permit, blocking if necessary. * * @throws InterruptedException * if interrupted while waiting for a permit */ public void acquire() throws InterruptedException { this.semaphore.acquire(); } /** * A trivial subclass of <code>Semaphore</code> that exposes the reducePermits * call to the parent class. Doug Lea says it's ok... * http://osdir.com/ml/java.jsr.166-concurrency/2003-10/msg00042.html */ private static final class ResizeableSemaphore extends Semaphore { /** * */ private static final long serialVersionUID = 1L; /** * Create a new semaphore with 0 permits. */ ResizeableSemaphore() { super(0); } @Override protected void reducePermits(int reduction) { super.reducePermits(reduction); } } }
这里可参考:http://blog.teamlazerbeez.com/2009/04/20/javas-semaphore-resizing/
相关推荐
在计算机操作系统中,信号量(Semaphore)是一种非常重要的同步机制,用于解决多个进程之间的资源竞争问题。本项目针对的是Linux 0.11内核,它是一个早期版本的开源操作系统,对于理解操作系统底层原理有着重要价值...
它是一个整型变量,可以被增减,并且可以被信号量操作(如`sem_wait()`和`sem_post()`)挂起或唤醒任务。`sys_sem.c`和`sys_sem.h`文件中,可能会包含信号量的初始化、等待、释放等相关函数,如`sem_init()`用于初始...
每个系统调用都涉及对信号量状态的管理,包括其值的增减以及对阻塞进程队列的处理。例如,SEM_POST操作会增加信号量的值,若值小于等于0,就唤醒阻塞队列中最先被阻塞的进程。 生产者消费者问题是多进程同步的经典...
`Producer`函数中,`Produce`函数模拟生产新产品,然后使用`Append`函数将产品放入缓冲区,同时处理信号量的增减。`Consumer`函数则从缓冲区取出产品并消费,同样需要处理信号量的同步。 通过这样的设计,生产者-...
在这个测试案例中,我们利用了信号量(Semaphore)进行任务间的同步和资源管理。信号量是一种多任务间共享资源的机制,可以理解为一种计数器,其值的增减用于控制任务的执行顺序。例如,我们可以创建一个计数值为1的...
PV操作源于信号量(Semaphore)的概念,分为P操作(Wait或Acquire)和V操作(Signal或Release)。这些操作用于控制对共享资源的访问,确保并发执行的进程能够正确地协调它们的执行顺序,避免数据竞争和死锁等问题。 ...
为了解决这个问题,通常使用信号量(Semaphore)和PV操作。信号量是一种同步原语,用于控制对共享资源的访问。在生产者-消费者问题中,我们可以设置两个信号量:一个是用于保护缓冲区的信号量full,其初始值为0,...
在操作系统领域,PV操作是进程同步的基本工具,源自荷兰计算机科学家埃德加·科德(Edsger Dijkstra)提出的信号量(Semaphore)概念。PV操作由两个原子操作组成:P(Wait)操作和V(Signal)操作,主要用于解决多...
为了实现进程间的协作,Linux提供了多种IPC机制,包括管道(Pipe)、消息队列(Message Queue)、信号量(Semaphore)、共享内存(Shared Memory)、套接字(Socket)以及有名管道(FIFO)等。 1. **管道**:管道是...
9. **信号量 (Semaphore)**:信号量是一种同步机制,用于保护共享资源。它可以是整型变量,通过wait()和signal()操作进行增减,确保对资源的互斥访问。 10. **LUT (Look-up Table)**:查找表是预存信息的数据结构,...
而"sem"文件名暗示这可能是关于信号量(Semaphore)的源代码或文档,信号量在多任务系统中用于同步和互斥访问共享资源,是T-KERNEL中的关键机制之一。 深入研究这些源码,开发者可以了解到T-KERNEL如何实现任务调度...
4. **信号量**:信号量用于解决资源的互斥访问和同步问题,通过计数值的增减来控制多个进程对共享资源的访问。 5. **共享内存**:共享内存允许进程直接读写同一块内存区域,速度快但需要额外的同步机制,如互斥锁,...
Java的`java.util.concurrent`包提供了许多并发工具类,如`Semaphore`(信号量)、`CountDownLatch`(计数器门锁)等,这些工具可以帮助我们更好地管理并发资源。 8. **线程通信** 使用`wait()`、`notify()`和`...
了解如何使用互斥体(mutex)、信号量(semaphore)和条件变量(condition variable)进行线程间的同步,比如互斥体的初始化、锁定、解锁操作,信号量的增减以及条件变量的等待与通知。 2. 自旋锁(spinlock)和...
- **同步**:Windows CE 提供了多种同步机制,包括互斥体(Mutex)、信号量(Semaphore)、事件(Event)等,其中 Mutex、Semaphore 和 Event 可以实现跨进程同步,而 CriticalSection 和 InterlockedFunctions 则...
在多线程环境下,可能需要使用互斥锁(mutex)或者信号量(semaphore)来实现同步。 4. **客户管理**:每个账户都关联一个客户,因此需要有客户类来存储客户信息。可能还包括添加新客户、删除客户、查找客户等功能...