org.apache.avalon.excalibur.concurrent
クラス DijkstraSemaphore

java.lang.Object
  |
  +--org.apache.avalon.excalibur.concurrent.DijkstraSemaphore
直系の既知のサブクラス:
DjikstraSemaphore

public class DijkstraSemaphore
extends java.lang.Object

Also called counting semaphores, Djikstra semaphores are used to control access to a set of resources. A Djikstra semaphore has a count associated with it and each acquire() call reduces the count. A thread that tries to acquire() a Djikstra semaphore with a zero count blocks until someone else calls release() thus increasing the count.

導入されたバージョン:
4.0
バージョン:
CVS $Revision: 1.2 $ $Date: 2001/12/11 09:53:27 $
作成者:
Karthik Rangaraju

コンストラクタの概要
DijkstraSemaphore(int maxCount)
          Creates a Djikstra semaphore with the specified max count and initial count set to the max count (all resources released)
DijkstraSemaphore(int maxCount, int initialCount)
          Creates a Djikstra semaphore with the specified max count and an initial count of acquire() operations that are assumed to have already been performed.
 
メソッドの概要
 void acquire()
          If the count is non-zero, acquires a semaphore and decrements the count by 1, otherwise blocks until a release() is executed by some other thread.
 void acquireAll()
          Tries to acquire all the semaphores thus bringing the count to zero.
 void release()
          Releases a previously acquires semaphore and increments the count by one.
 void release(int count)
          Same as release() except that the count is increased by pCount instead of 1.
 void releaseAll()
          Releases all semaphores setting the count to max count.
 void starvationCheck()
          This method blocks the calling thread until the count drops to zero.
 boolean tryAcquire()
          Non-blocking version of acquire().
 
クラス java.lang.Object から継承したメソッド
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

コンストラクタの詳細

DijkstraSemaphore

public DijkstraSemaphore(int maxCount)
Creates a Djikstra semaphore with the specified max count and initial count set to the max count (all resources released)
パラメータ:
pMaxCount - is the max semaphores that can be acquired

DijkstraSemaphore

public DijkstraSemaphore(int maxCount,
                         int initialCount)
Creates a Djikstra semaphore with the specified max count and an initial count of acquire() operations that are assumed to have already been performed.
パラメータ:
pMaxCount - is the max semaphores that can be acquired
メソッドの詳細

acquire

public void acquire()
             throws java.lang.InterruptedException
If the count is non-zero, acquires a semaphore and decrements the count by 1, otherwise blocks until a release() is executed by some other thread.
例外:
java.lang.InterruptedException - is the thread is interrupted when blocked
関連項目:
tryAcquire(), acquireAll()

tryAcquire

public boolean tryAcquire()
Non-blocking version of acquire().
戻り値:
true if semaphore was acquired (count is decremented by 1), false otherwise

release

public void release()
Releases a previously acquires semaphore and increments the count by one. Does not check if the thread releasing the semaphore was a thread that acquired the semaphore previously. If more releases are performed than acquires, the count is not increased beyond the max count specified during construction.
関連項目:
release( int pCount ), releaseAll()

release

public void release(int count)
Same as release() except that the count is increased by pCount instead of 1. The resulting count is capped at max count specified in the constructor
パラメータ:
pCount - is the amount by which the counter should be incremented
関連項目:
release()

acquireAll

public void acquireAll()
                throws java.lang.InterruptedException
Tries to acquire all the semaphores thus bringing the count to zero.
例外:
java.lang.InterruptedException - if the thread is interrupted when blocked on this call
関連項目:
acquire(), releaseAll()

releaseAll

public void releaseAll()
Releases all semaphores setting the count to max count. Warning: If this method is called by a thread that did not make a corresponding acquireAll() call, then you better know what you are doing!
関連項目:
acquireAll()

starvationCheck

public void starvationCheck()
                     throws java.lang.InterruptedException
This method blocks the calling thread until the count drops to zero. The method is not stateful and hence a drop to zero will not be recognized if a release happens before this call. You can use this method to implement threads that dynamically increase the resource pool or that log occurences of resource starvation. Also called a reverse-sensing semaphore
例外:
java.lang.InterruptedException - if the thread is interrupted while waiting


"Copyright ? 2001 Apache Jakarta Project. All Rights Reserved."