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 ConditionVariable

java.lang.Object
  extended byorg.wegra.thread.Lock
      extended byorg.wegra.thread.ConditionVariable
All Implemented Interfaces:
Condition
public class ConditionVariable
extends org.wegra.thread.Lock
implements Condition

이 클래스는 "조건 변수"를 간단하게 구현해 놓은 클래스이다. "조건 변수"는 어떤 조건이 만족되는 경우에만 스레드가 기다리도록 하기 위한 것으로 만약 조건이 만족되지 않았다면 스레드는 블록킹 되지 않는다. "조건 변수"를 사용하면서는 중첩된 모니터에 의해서 나타날 수 있는 교착 상태를 조심해야 한다. 

	class Lockout {
		ConditionVariable fCondition = new ConditionVariable(false);

		synchronized void f() {
			// do work
			fCondition.waitFotTure();
		}

		synchronized void set() {	// f()에서 다른 스레드가 블록킹 되어있는
			fCondition.setCondition(true);	// 교착 상태가 일어난다.
		}
	}
위의 코드에서는 어떤 스레드가 ㄹ()로 진입해서 모니터를 얻은 다음 조건 변수가 참이 될 때까지 기다릴 수 있다. 이 때 모니터의 락을 놓는 것은 아니라는 것에 유의해야 한다. (위의 코드에서 fCondition 이 참이 되는 경우는 오직 set() 을 호출하는 방법 밖에 없다. 하지만 set() 을 호출했을 경우 이미 f() 를 호출한 스레드에서 모니터를 가지고 있으므로 블록킹 되게 된다. 결론적으로, 위의 코드에서는 중첩된 모니터에 의한 교착 상태가 나타날 수 있다) 위의 문제를 풀기 위해서는 조건 변수가 참이 되길 기다리는 코드 이전에 모니터를 놓아 주어야 한다. 
	class Okay {
		ConditionVariable fCondition = new ConditionVariable(false);

		void f() {
			synchronized( this ) {
				// do work
			}
			fCondition.waitForTrue();
		}
		synchronized void set() {
			fCondition.setCondition(true);
		}
	}
아니면 set() 메소드를 통기화 하지 말아야 한다. 
	class Okay {
		ConditionVariable fCondition = new ConditionVariable(false);
		synchronized void f() {
			// do work
			fCondition.waitForAll();
		}

		void set() {
			fCondition.waitForTure();
		}
	}
일반적인 wait() , notify 방식에서는 wait() 가 블록킹 되지 전에 모니터를 놓아주기 때문에 이와 같은 문제가 발생하지 않는다. 하지만 모든 경우 쓸 수 있는 건 아니다.

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

Constructor Summary
ConditionVariable()
          초기 조건이 거짓 상태인 조건변수를 생성한다.
ConditionVariable(boolean condition)
          특정 상태의 조건 변수를 생성한다.
 
Method Summary
 boolean acquire(long timeout)
          Semaphore 구현을 위한 메소드 waitForTrue(long)와 동일
 void awake()
          블록킹 되어있는 스레드 중 하나를 깨운다.
 void awakeAll()
          모든 블록킹 스레드를 깨운다.
 int getID()
          해당 세마포어 객채의 고유 ID를 반환
 boolean isSatisfied()
          조건 변수가 참일 경우에 true를 반환한다.
 void release()
          Semaphore 구현을 위한 클래스 setCondition(boolean)와 동일
 void setCondition(boolean condition)
          조건을 주어진 상태로 재설정한다.
 boolean waitForTrue()
          조건이 참으로 될 때까지 대기한다(잠재적으로 영원히 기다릴 수도 있다).
 boolean waitForTrue(long timeout)
          조건이 참이 될 때까지 기다린다.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ConditionVariable

public ConditionVariable()
초기 조건이 거짓 상태인 조건변수를 생성한다.

ConditionVariable

public ConditionVariable(boolean condition)
특정 상태의 조건 변수를 생성한다.

Method Detail

acquire

public boolean acquire(long timeout)
                throws java.lang.InterruptedException,
                       TimeoutException,
                       java.lang.IllegalArgumentException
Semaphore 구현을 위한 메소드 waitForTrue(long)와 동일

Returns:
만약 타임아웃 값이 0이고 락을 얻을 수 없었을 경우 false를 반환하며 그 외의 경우 true를 반환한다.
Throws:
TimeoutException - 세마포어가 얻어지기 전에 타임아웃이 다 지나간 경우.
java.lang.InterruptedException - 다른 스레드에 의해서 락을 얻는 것이 인터럽트 되었을 경우.
java.lang.IllegalArgumentException

awake

public final void awake()
블록킹 되어있는 스레드 중 하나를 깨운다. (내부적으로 단지 notify() 메소드를 호출할 뿐이나 동기화되어 있다는 차이점이 있다)

awakeAll

public final void awakeAll()
모든 블록킹 스레드를 깨운다. 이 메소드는 자바 원래의 wait / notify 처럼 현재 상태와 관계없이 제어하고 싶을 때 사용한다. 이 메소드를 통해 깨어나는 스레드는 이미 블록킹 되어있던 스레드들로 한정되며 이 메소드 호출 후에도 여전히 조건에 따라 다시 블록킹 될 수 있다. (내부적으로 단지 notifyAll() 메소드를 호출할 뿐이나 동기화되어 있다는 차이점이 있다)

isSatisfied

public final boolean isSatisfied()
조건 변수가 참일 경우에 true를 반환한다. 이 메소드를 호출하는 것은 잠재적으로 위험할 수 있는데 이 메소드 호출 후 조건 변수는 언제라도 변할 수 있기 때문이다.

Specified by:
isSatisfied in interface Condition

release

public void release()
Semaphore 구현을 위한 클래스 setCondition(boolean)와 동일

setCondition

public void setCondition(boolean condition)
조건을 주어진 상태로 재설정한다. 새로운 상태가 'true'이라면 블록킹되어 있는 스레드들을 깨워준다.

waitForTrue

public final boolean waitForTrue()
                          throws java.lang.InterruptedException
조건이 참으로 될 때까지 대기한다(잠재적으로 영원히 기다릴 수도 있다). 이 메소드는 waitForTure(Semaphore.TIMEOUT_FOREVER); 를 사용하는 것보다 아주 조금이나마 더 효율적이다.

Throws:
java.lang.InterruptedException

waitForTrue

public final boolean waitForTrue(long timeout)
                          throws java.lang.InterruptedException,
                                 TimeoutException,
                                 java.lang.IllegalArgumentException
조건이 참이 될 때까지 기다린다.

Parameters:
timeout - 밀리초 단위, 0이 주어지면 곧바로 반환한다.
Returns:
timeout이 0으로 주어지고 조건이 거짓인 경우 false를 반환 그 외의 경우 true를 반환한다.
Throws:
java.lang.InterruptedException
TimeoutException
java.lang.IllegalArgumentException

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