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 ThreadPool

java.lang.Object
  extended byjava.lang.ThreadGroup
      extended byorg.wegra.thread.ThreadPool
public final class ThreadPool
extends java.lang.ThreadGroup

스레드 풀에 대한 범용적인 구현. 다음과 같이 사용할 수 있다. 

	ThrreadPool pool = new ThreadPool();
	pool.execute( new Runnable() {
		public void run() {
			// 이 부분은 풀 안의 스레드에 의해서 샐행된다.
		}
	}
스레드 풀의 크기는 요청에 따라서 자동적으로 증가할 수 있다. 만약 스레드 풀 내의 스레드 개수가 충분할 경우라면 남는 스레드를 사용해 요청을 수행하지만, 그렇지 않은 경우라면 새롭게 스레드를 만들어 요청을 수행한다. 하지만 풀이 최대로 커질 수 있는 크기는 지정해줄 수 있다. 각각의 스레드 풀은 스레드 그룹을 이룬다. 실용적인 관점에서 볼 때 각각의 스레드 풀이 스레드 구룹이라는 사실은 보안 매니저에서 다른 그룹의 스레드에 접근할 수 있는지를 관장한다는 것을 의미하며, 풀 내의 모든 스레드들은 쉽게 데몬으로 지정할 수 있음을 의미한다. ThreadGroup과는 다르게 스레드 풀에는 join() 메소드가 있으며 여기서는 wait() 를 사용해서 스레드 풀의 종료를 기다릴 수 있게 해준다. 
 ThreadPool pool = new ThreadPool();
	//...
	try {
		synchronized(pool) {
			pool.wait();
		}
	} catch( InterruptedException ie) {
		// 에러 발생
	}
위의 코드가 편의상 join()으로써 구현된 것이다. 스레드를 인터럽트 하면 스레드가 풀에서 빠져나오게 된다. 이렇게 하는 가장 쉬운 방법은 다음과 가이 실행될 작업 자체에서 인터럽트를 걸어버리는 방법이다. 
	pool.execute( new Runnable() {
			public void run() {
				interrupte();	// 스레드를 풀로부터 제거한다.
			}
		}
	);
하지만 deflate(boolean) 메소드를 사용하면 풀의 초기 크기를 초과하는 수의 스레드를 풀로부터 제거해줄 수 있다. 따라서, 위와 같이 인터럽트를 거는 방식보다 이 메소드를 사용하는 것이 더 바람직하다.

Version:
1.0 (2001-08-31)
Author:
wegra(Bok-Youn Lee)

Nested Class Summary
static class ThreadPool.Test
          테스트 클래스
 
Field Summary
static int MAX_CAPACITY
          ThreadPool 에 저장될 수 있는 최대 Thread 수
 
Constructor Summary
ThreadPool()
          기본적인 스레드 풀을 생성한다.
ThreadPool(int initSize, int maxSize)
          initSize 만큼의 초기 스레드를 가지는 스레드 풀을 생성한다.
 
Method Summary
 void close()
          풀에서 대기하고 있는 모든 스레드를 종료한다.
 void deflate(boolean doDeflate)
          만약 인자가 true로 지정되면 최초로 주어진 풀의 크기까지 압축된다.
 void execute(java.lang.Runnable action)
          현재 풀에 있는 스레드를 사용해서 Runnable 객체의 run() 메소드를 실행한다.
 void execute(Subscriber action, java.lang.Object argument)
          현재 풀에 있는 스레드를 사용해서 Command 객체의 execute() 메소드를 실행한다.
 void join()
          풀에서 더 이상 실행되는 스레드가 없을 때까지 기다린다.
 
Methods inherited from class java.lang.ThreadGroup
activeCount, activeGroupCount, allowThreadSuspension, checkAccess, destroy, enumerate, enumerate, enumerate, enumerate, getMaxPriority, getName, getParent, interrupt, isDaemon, isDestroyed, list, parentOf, resume, setDaemon, setMaxPriority, stop, suspend, toString, uncaughtException
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

MAX_CAPACITY

public static final int MAX_CAPACITY
ThreadPool 에 저장될 수 있는 최대 Thread 수

See Also:
Constant Field Values
Constructor Detail

ThreadPool

public ThreadPool()
기본적인 스레드 풀을 생성한다.

ThreadPool

public ThreadPool(int initSize,
                  int maxSize)
initSize 만큼의 초기 스레드를 가지는 스레드 풀을 생성한다. 풀의 크기는 요청에 따라 커질 수 있다.

Parameters:
initSize - 초기 스레드 개수. 만약 초기치가 회대치보다 크게 주어졌을 경우 최대치에 맞게 줄어든다.
maxSize - 풀의 최대 크기.
Method Detail

close

public void close()
풀에서 대기하고 있는 모든 스레드를 종료한다. 풀 안의 모든 스데르는 풀 밖으로 나오게 된다. 하지만 현재 실행 중인 스레드라면 무엇을 하고 있던 간에 자신이 하고 있던 일을 전부 다 수행한 후에 종료된다. execute(0 를 통해 실행이 요청되었으나 아직 이에 할당된 스레드가 없는 작업은 취소된다. 풀이 종료된 이후에는 어떠한 작업도 할 수 없다. 이미 종료된 풀에 다시 종료 요청을 보낼 경우 이 요청은 무시된다.

deflate

public void deflate(boolean doDeflate)
만약 인자가 true로 지정되면 최초로 주어진 풀의 크기까지 압축된다. 즉, 풀 안의 스레드의 갯수는 초기 갯수보다 적어지지 않지만 만약 스레드의 갯수가 초기 갯수보다 늘어나는 경우에는 풀의 스레드 갯수가 초기치로 다시 줄어들게 된다. 이 메소드는 풀의 코든 스레드들이 활성화 되기 전에 사용하는 것이 좋다. 만약 인자가 false로 지정되면(스레드 풀에서 사용하는 기본값은 false) 확장된 스레드 풀의 크기는 줄어들지 않는다.

execute

public void execute(java.lang.Runnable action)
             throws ClosedQueueException
현재 풀에 있는 스레드를 사용해서 Runnable 객체의 run() 메소드를 실행한다. 풀에 사용 가능한 스레드가 없다면 새롭게 스레드를 만들어 풀에 추가하지만 이는 풀의 최대 스레드 갯수를 넘지 않을 때 까지만 가능하다.

Throws:
ClosedQueueException - close() 요청을 보낸 후에 풀에 뭔가 작업을 요청했을 때 발생한다.

execute

public final void execute(Subscriber action,
                          java.lang.Object argument)
                   throws ClosedQueueException
현재 풀에 있는 스레드를 사용해서 Command 객체의 execute() 메소드를 실행한다. 풀에 사용 가능한 스레드가 없다면 새롭게 스레드를 만들어 풀에 추가하지만 이는 풀의 최대 스레드 갯수를 넘지 않을 때까지만 가능하다. argument의 값은 실제 작업이 실행될 때의 값이 사용된다. 즉, execute()를 호출할 때 넘겨준 값이 실제로 실행되기 전에 바뀐다면 바뀐 값이 실행될 때 사용된다.

Throws:
ClosedQueueException - 이미 종료된 풀에 대해 작업을 요청했을 경우.

join

public void join()
풀에서 더 이상 실행되는 스레드가 없을 때까지 기다린다. 이 메소드는 다음과 같은 역할을 한다. 
	ThreadPool pool = new ThreadPool();
	//..
	try {
		synchronized( pool ) {
			pool.wait();
		}
	} catch ( InterruptedException ie) {
 		// 무시
	}

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