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.util.dispatcher
Class AsynchronousDispatcher

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.wegra.util.dispatcher.AsynchronousDispatcher
All Implemented Interfaces:
java.lang.Runnable
public final class AsynchronousDispatcher
extends java.lang.Thread

활성 객체(Active Object)를 구현하기 위해서 사용되는 디스패쳐 다음과 같은 식으로 디스패쳐를 생성하고 시작할 수 있다. 

	AsynchronousDispatcher dispatcher = new AsynchronousDispatcher();
	dispatcher.start();

	dispatcher.dispatch(	// 사용
		new Runnable() {
			System.out.println("hello world");
		}
	);

	dispatcher.close();	// 종료

Version:
1.0 (2001-09-02)
Author:
wegra(Bok-Youn Lee)

Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
AsynchronousDispatcher()
          디스패쳐를 생성한다.
 
Method Summary
 void close()
          디스패쳐를 종료한다.
 void dispatch(java.lang.Runnable operation)
          지정된 작업이 현재 디스페쳐의 이벤트 처리 스레드에서 실행될 수 있도록 해준다.
 void dispatch(Subscriber action, java.lang.Object argument)
          인자로 Command 객체를 받아 디스패치한다.
 void run()
          이 메소드가 public 인 이유는 Thread를 바로 상속 받았기 때문이다.
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AsynchronousDispatcher

public AsynchronousDispatcher()
디스패쳐를 생성한다. 이 객체는 dispatch() 요처을 기다리는 데몬 스레드이다. 요청이 오면 요청 순서대로 작업이 실행된다. 스레드가 데못 스레드이므로 다른 일반 스레드가 모두 종료되면 함께 종료된다.

Method Detail

close

public final void close()
디스패쳐를 종료한다. 즉, 더 이상 작업 요청을 받아들이지 않는다. 종료 요청 시에 아직 수행되지 않고 있던 모든 작업은 예정대로 실행되며 단지, 새로운 작업을 받아들이지 않을 뿐이다. 이 메소드는 나머지 작업들이 모두 수행되지 않은 생태라도 곧바로 복귀한다. 디스패쳐의 모든 작업이 완전히 끝날 때까지 기다리기 위해서는 디스패쳐 객체에 join() 메시지를 보내면 된다. AsynchronousDispatcher dispatcher = new AsynchronousDispatcher(); //.. dispatcher.close(); // 새로운 요청을 거부한다. dispatcher.join(); // 나머지 작업들이 모두 처리될 때까지 기다린다. dispatch(null) 를 호출해도 마찬가지로 디스패쳐를 블록킹 없이 종료할 수 있다. 이 때에도 마찬가지로 dispatch(null) 이후 요청되는 모든 요청은 무시된다. 하지만 close() 를 사용했을 경우와 다르게 예외를 발생시키지 않는다. 이미 종료된 큐에 대해서 다시 close() 를 호출하는 경우 무시된다.

dispatch

public final void dispatch(java.lang.Runnable operation)
지정된 작업이 현재 디스페쳐의 이벤트 처리 스레드에서 실행될 수 있도록 해준다. 작업은 요청된 순서대로 차례차례 실행된다.

Parameters:
operation - "커맨트" 객체로 수행할 작업을 캡슐화한다. 만약 operation 이 null일 경우 디스패쳐는 이 요청이 큐로부터 빠져나올 때 종료된다. null을 인자로 한 호출 이휴에 요청되는 작업은 실행되지 않는다.
Throws:
ClosedQueueException - 이미 종료된 상태에서 작업을 요청하면 발생한다. 단, close()를 통해 명시적으로 종료된 경우에만 발생한다.

dispatch

public final void dispatch(Subscriber action,
                           java.lang.Object argument)
                    throws ClosedQueueException
인자로 Command 객체를 받아 디스패치한다.

Throws:
ClosedQueueException

run

public void run()
이 메소드가 public 인 이유는 Thread를 바로 상속 받았기 때문이다. 따라서, 이 메소드를 직접 호출해서는 안된다. 디스패쳐의 이벤트 순환문이 이 메소드에 구혀되어 있다.

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