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 RWLock

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

읽기/쓰기 락은 쓰는 도중 읽거나, 읽는 도중 쓰거나 하는것을 막아준다. 또한, 여러 쓰레드에서 동시에 쓰는 것도 막아준다. 하지만 여러 스레드에서 동시에 읽는 것은 허용된다. 읽기는 쓰기보다 놓은 우선순위를 가지는데 이로 인해 쓰기가 마쳐질 때까지 미뤄졌던 모든 읽기는 항상 다음 쓰긱가 진행되기 전에 먼저 수행된다. 모든 쓰기는 요청된 순서대로 이뤄지도록 ㅎ보장된다. 즉, 가장 먼저 요청된 쓰기가 가장 먼저 처리된다. 읽ㄱ/쓰기 락은 다음과 같이 사용할 수 있다. 

	public class DAtaStructureOrResourse {
		RWLock lock = new RWLock();
		public void access() throws InterrruptedException {
			lock.requestRead();
			try {
				// 읽기를 여기에서 한다.
			} finally {
				lock.readAccomplished();
			}
		}

		public void modify() throws InterruptedException {
			lock.requestWrite();
			try {
				// 쓰기를 여기에서 한다.
			} finally {
				lock.writeAccomplished()'
			}
		}
	}
n현재 구현된 RWLock은 타임아웃을 지원하지 않는다. RWLock은 Dong Lead의 Concurrent Programming in Java (Addision Wedley, 1997, pp.300-303) 의 읽기/쓰기 락을 기반으로 작성되었다. 필자는 코드를 단순화 했으며, 블록킹 없이 락을 얻는 기능을 추가했다. 또한, 읽기/쓰기 락을 기반 클래스로써 여러분이 상속받아 쓰도록 하지 않고 독립형 클래스로써 구현했다. Scott Osk과 Henry Wong이 집필한 JavaThread(O'Reilly 1997, pp. 180-187)에는 필자의 것과 전혀 다르게 읽기/쓰기 락을 구현해 놓았으니 참조하기 바란다.

Author:
wegra(Bok-Youn Lee) version: 1.0 (2001-08-11)

Nested Class Summary
static class RWLock.Test
           Test 클래스는 단위 테스트를 위한 클래스로 다음과 같이 실행시킬 수 있다.
 
Constructor Summary
RWLock()
          RWLock constructor comment.
 
Method Summary
 boolean acquire(long timeout)
          세마포어를 얻는다.
 int getID()
          해당 세마포어 객채의 고유 ID를 반환
 void readAccomplished()
          락을 놓는다.
 void release()
          세마포어를 놓는다.
 boolean requestImmediateRead()
          이 요청은 읽기가 가능할 경우 true를 반환한다.
 boolean requestImmediateWrite()
          블록킹 없이 쓰기 요청을 한다.
 void requestRead()
          읽기 락을 요청하낟.
 void requestWrite()
          쓰기를 요청한다.
 void writeAccomplished()
          락을 놓는다.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

RWLock

public RWLock()
RWLock constructor comment.

Method Detail

acquire

public boolean acquire(long timeout)
                throws java.lang.InterruptedException,
                       TimeoutException
세마포어를 얻는다. 예를 들어 Mutex의 경우 소유권을 얻으라는 뜻이며, CountingSemaphore의 경우 카운트를 하나 감소시키라는 뜻이다.

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

readAccomplished

public void readAccomplished()
락을 놓는다. 읽기 과정을 마치면 이 메소드를 호출해야만 한다.

release

public void release()
세마포어를 놓는다.

requestImmediateRead

public boolean requestImmediateRead()
이 요청은 읽기가 가능할 경우 true를 반환한다. 만약, 현재 읽을 수 없는 상황이라면 false를 반환한다. true를 반환해서 읽기가 가능할 경우 읽기를 마친 후에는 반드시 다음과 같이 해주어야 한다. 
	public void read() {
		if ( lock.requestImmediateRead() ) {
			try {
				// 여기에서 읽기를 한다.
			} finally {
				lock.readAccomplished();
			}
		} else {
			// 읽을 수 없었다.
		}
	}

requestImmediateWrite

public boolean requestImmediateWrite()
블록킹 없이 쓰기 요청을 한다. 만약 읽기나 쓰기가 이미 진행중이라면 false를 반환한다. 만약 쓰기가 가능한 상태라면 true를 반환한다. 다음과 같이 사용하면 된다. 
	public void write() {
		if (lock.requestimmediateWrite() ) {
			try {
				// 여기에서 쓰기를 한다.
			} finally {
				// lock.writeAccomplished()
			}
		} else {
			// 쓸 수 없었다.
		}

requestRead

public void requestRead()
                 throws java.lang.InterruptedException
읽기 락을 요청하낟. 읽기가 가능할 때까지 블록킹 된다. 이 메소드를 호출한 다음 읽기를 마친 다음에는 반드시 readAccomplished() 를 호출해야 한다.

Throws:
java.lang.InterruptedException

requestWrite

public void requestWrite()
                  throws java.lang.InterruptedException
쓰기를 요청한다. 실제 쓰기가 일어날 수 있을 때까지 블록킹 된다. 쓰기는 항상 요청된 순서대로 일어나게 된다. 쓰기가 마칠 때까지 연기되었던 읽기 요청들은 다음 쓰기 요청이 실행되기 전에 수행된다. 쓰기를 모두 끝마친 다음에는 반드시 writeAccomplished() 를 호출해 주어야 한다.

Throws:
java.lang.InterruptedException

writeAccomplished

public void writeAccomplished()
락을 놓는다. 쓰기를 모두 마친 다음에는 꼭 이 메소드를 호출해 주어야 한다.

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