Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.wegra.thread
Class Semaphore

java.lang.Object
  extended byorg.wegra.thread.Lock
      extended byorg.wegra.thread.Semaphore
public final class Semaphore
extends org.wegra.thread.Lock

일반적인 세마포어를 구현한다. 배타적 세마포어는 Mutex라는 별도의 클래스로 제공되며 이 클래스의 인스턴스는 일반적으로 카운팅 세마포어의 역할을 수행한다.

Version:
1.0 (2001-07-29)
Author:
wegra (Bok-Youn Lee)

Constructor Summary
Semaphore()
          Semaphore constructor comment.
 
Method Summary
 boolean acquire(long timeout)
          세마포어를 얻는다.
 boolean acquireAll(int number, long timeout)
          지정된 개수의 슬롯을 얻는다.
 int getID()
          해당 세마포어 객채의 고유 ID를 반환
 int getMaxSize()
          현재 풀의 크기를 반환한다.
 void increaseMaxSlots(int number)
          최대 풀의 크기를 number 만큼 늘린다.
 void release()
          세마포어를 놓아주고 카운트를 증가시킨다.
 int release(int number)
          세마포어의 슬롯을 한 번에 "number"만큼 놓는다.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Semaphore

public Semaphore()
Semaphore constructor comment.

Method Detail

acquire

public boolean acquire(long timeout)
                throws java.lang.InterruptedException,
                       TimeoutException,
                       java.lang.IllegalArgumentException
세마포어를 얻는다. 즉, 가능한 슬롯의 개수를 감소시킨다. 이 때 슬롯의 개수가 0이라면 블록킹 된다. 만약 이 메소드를 호출해서 마지막 슬롯을 얻었다면 생생자에 지정된 Runnable 객체의 run() 메소드 호출된다. 이런 방식을 사용하면 필요에 따라 풀의 크리를 늘려줄 수 있다. (increaseMaxSlots(int) 참고)

Returns:
timeout을 0으로 주었을 때 슬롯을 얻지 못하면 false를 반환한다. 그 외의 경우는 모두 true를 반환한다.
Throws:
java.lang.InterruptedException - 블록팅이 인터럽트 되었을 경우
TimeoutException - 세마포어가 얻어지기 전에 타임아웃이 다 지나간 경우.
java.lang.IllegalArgumentException

acquireAll

public boolean acquireAll(int number,
                          long timeout)
                   throws java.lang.InterruptedException,
                          TimeoutException,
                          java.lang.IllegalArgumentException
지정된 개수의 슬롯을 얻는다. 여러개의 슬롯을 한꺼번에 얻기 위해서는 LockManager.acquireAll() 를 사용하면 된다. 즉, 하나의 Semaphore 에 대한 여러개의 참조자를 담은 배열을 LockManager의 acquireAll() 호출에 사용하면 된다.

Parameters:
timeout - 하나의 슬롯을 얻는데 까지 기다릴 최대시간(ms) 따라서, 기다리는데 걸릴 수 있는 최대시간은 timeout * number 이다.
Throws:
TimeoutException - 만약 슬롯을얻고자 할 때 타임아웃이 일어난다면 발생
java.lang.InterruptedException
java.lang.IllegalArgumentException

getMaxSize

public int getMaxSize()
현재 풀의 크기를 반환한다.

increaseMaxSlots

public void increaseMaxSlots(int number)
최대 풀의 크기를 number 만큼 늘린다. 만약 사용 가능한 슬롯이 없는 경우였다면 슬롯을 얻기 위해 기다리는 스레드들은 깨어나게 된다(새롭게 지정된 슬롯마저 다 찰때까지). 즉, 이 메소드는 현재 가능한 슬롯의 개수를 늘리고 release(number) 를 호출하는 것이다.

Parameters:
number - 새롭게 추가할 슬롯의 개수. 만약 0 이하의 값으로 지정되면 IllegalArgumentException 이 발생한다.

release

public void release()
세마포어를 놓아주고 카운트를 증가시킨다. 이 메소드는 일반적인 세마포어의 release()를 구현한 것이다.

Throws:
OverflowException - 더 이상 놓아줄 세마포어가 없는 상태에서 세마포어를 놓아주려 하는 경우

release

public int release(int number)
세마포어의 슬롯을 한 번에 "number"만큼 놓는다.

Parameters:
number - 놓아줄 슬롯의 개수. 이 값이 0 이하이면 IllegalArgumentException이 발생한다.
Returns:
증가가 일어난 이후 사용 가능한 슬롯의 개수
Throws:
OverflowException - 현재 사용중인 슬롯 개수 + 놓아주려는 개수가 최대치를 넘어서면 발생한다. 예외가 발생하면 슬롯의 개수는 소출 전과 변화가 없다.
IllegalOwnershipException - 생성자에서 enforcePnwership을 참으로 지정한 경우 현재 스레드가 자신이 얻은 슬롯보다 많은 수의 슬롯을 놓으려고 한다면 발생한다.

getID

public final int getID()
해당 세마포어 객채의 고유 ID를 반환

Returns:
고유 ID
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD