java.util.concurrent
클래스 ThreadPoolExecutor

java.lang.Object 
  java.util.concurrent.AbstractExecutorService 
      java.util.concurrent.ThreadPoolExecutor

모든 구현된 인터페이스:

Executor, ExecutorService

알려진 직계 서브 클래스:

ScheduledThreadPoolExecutor

public class ThreadPoolExecutor
extends AbstractExecutorService 

많은 경우, 풀 된 복수의 thread의 어느쪽이든을 사용해, 송신된 각 태스크를 실행하는 ExecutorService . 일반적으로Executors 팩토리 메서드를 사용해 구성됩니다.

thread 풀은 태스크마다의 호출의 오버헤드를 감소시키는 것으로 대량의 비동기 태스크를 실행할 때의 퍼포먼스를 개선해, 태스크의 컬렉션을 실행할 때에 소비되는 thread등의 자원을 제한 및 관리하는 수단을 제공하는 것으로 다른 2개의 문제에 대응합니다. 각 ThreadPoolExecutor 도, 완료 태스크의 수등의 몇개의 기본적인 통계를 관리합니다.

광범위한 컨텍스트 으로 유용하기 때문에, 이 클래스는 조정 가능한 다수의 파라미터 및 확장 기능 훅을 제공합니다. 다만, 프로그래머는 보다 편리성의 높은 Executors 팩토리 메서드인 Executors.newCachedThreadPool() (안 바운드 형식의 thread 풀, 자동 thread 재생을 포함한다), Executors.newFixedThreadPool(int) (고정 사이즈의 thread 풀) 및 Executors.newSingleThreadExecutor() (단독의 백그라운드 thread)를 사용하는 것이 추천 되고 있습니다. 이러한 메서드는 일반적으로 사용되는 대부분의 시나리오에 맞추어 미리 설정되어 있습니다. 그렇지 않은 경우는 다음에 나타내는 가이드에 따라 이 클래스를 수동으로 구성 및 튜닝의해 주세요.

코어 및 최대 풀 사이즈

ThreadPoolExecutor는 corePoolSize (getCorePoolSize()를 참조) 및 maximumPoolSize (getMaximumPoolSize()를 참조)가 부과하는 제한에 따라, 풀 사이즈 (getPoolSize()를 참조)를 자동조정 합니다. 새로운 태스크가 execute(java.lang.Runnable) 메서드내에서 송신되어 corePoolSize thread보다 실행중의 수가 적은 경우, 다른 워카스레드가자식 돌 상태의 경우에서도, 요구를 처리하기 위해서 새로운 thread가 작성됩니다. 실행중의 수가 corePoolSize thread보다 많아, maximumPoolSize thread보다 적은 경우, 큐가 가득 되어 있는 경우에게만 새로운 thread가 작성됩니다. corePoolSize 및 maximumPoolSize를 같게 설정하는 것으로 고정 사이즈의 thread 풀을 작성합니다. maximumPoolSize을 Integer.MAX_VALUE 등의 원칙적으로 무제한한 값으로 설정하는 것으로 풀이 임의의 수의 동시 태스크를 받아들이는 것이 가능하게 됩니다. 보통, 코어 및 최대 풀 사이즈는 구축시에게만 설정됩니다만, setCorePoolSize(int) 및 setMaximumPoolSize(int)를 사용해 동적으로 변경하는 일도 가능합니다.

요구에 응한 구축

디폴트에서는 코어 thread가 최초로 작성되어 필요한 때만 새로운 태스크에 의해 시작되는 경우에서도, prestartCoreThread() 나 prestartAllCoreThreads() 메서드를 사용해 동적으로 오버라이드(override) 되는 경우가 있습니다.

새로운 thread의 작성

새로운 thread는 ThreadFactory를 사용해 작성됩니다. 지정되어 있지 않은 경우는 Executors.defaultThreadFactory()를 사용해, 작성하는 thread 모든 것이 같은 ThreadGroup, NORM_PRIORITY 우선도 및 비demon 상태를 보관 유지하도록 합니다. 다른 ThreadFactory를 지정하는 것으로 thread의 이름, thread 그룹, 우선 순위, demon 상태등을 변경할 수 있습니다. newThread로 부터 null이 돌려주고졌을 때에 요구된 ThreadFactory로 thread의 작성에 실패했을 경우, executor는 속행합니다만, 태스크를 실행할 수 없을 가능성이 있습니다.

킵얼라이브 시간

풀이 현재 corePoolSize를 넘는 thread를 보관 유지하고 있는 경우,자식 돌 상태의 시간이 keepAliveTime (getKeepAliveTime(java.util.concurrent.TimeUnit)를 참조)를 초과하면, 초과한 thread는 종료합니다. 이것에 의해 풀이 활성화 사용되어 있지 않은 경우에 자원의 소비를 억제할 수 있습니다 . 풀이 나중에보다 활성화 되면, 새로운 thread가 작성됩니다. 이 파라미터는 setKeepAliveTime(long, java.util.concurrent.TimeUnit) 메서드를 사용해 동적으로 변경하는 일도 가능합니다. Long.MAX_VALUE TimeUnit.NANOSECONDS 치를 사용하면,자식 돌 상태의 thread가 셧다운전에 종료하지 않게 할 수 있습니다.

큐잉

임의 BlockingQueue를 사용해, 송신 끝난 태스크를 전송 및 보관 유지할 수 있습니다. 이 큐를 사용하면, 풀의 사이즈 변경이 대화적으로 처리됩니다.

• 실행중의 thread가 corePoolSize 보다 적은 경우, Executor는 큐잉보다 새로운 thread의 추가를 항상 우선한다
• corePoolSize 이상의 thread가 실행중의 경우, Executor는 새로운 thread의 추가보다 요구의 큐잉을 항상 우선한다
• 요구를 큐에 넣을 수가 없는 경우, maximumPoolSize를 초과하지 않는 한, 새로운 thread가 작성된다. maximumPoolSize를 초과하는 경우, 태스크가 거부된다

큐잉에는 다음의 3개의 스트래터지가 있습니다.

1. 직접 핸드 오프. 작업 큐용이 뛰어난 디폴트 선택인 SynchronousQueue 는 thread를 따로 보관 유지하는 일 없이 thread에 건네준다. 여기서, 곧바로 실행 가능한 thread가 존재하지 않는 경우, 태스크를 큐에 넣으려고 하는 시도는 실패하기 위해, 새로운 thread가 작성된다. 이 정책는 내부 존성을 보관 유지할 가능성이 있는 요구 세트를 처리할 때, 록 업을 회피한다. 보통, 직접 핸드 오프에서는 새롭게 송신되는 태스크가 거부되는 것을 회피하기 위해서 안 바운드 형식의 maximumPoolSizes가 필요하게 된다. 한편, 이 경우 전체적으로 처리 능력을 넘는 속도로 커멘드가 차례차례로 도착하면, 안 바운드 형식의 thread가 커질 가능성이 있다
2. 안 바운드 형식의 큐. 안 바운드 형식의 큐 (정의 끝난 용량을 가지지 않는 LinkedBlockingQueue 등)를 사용하면, 모든 corePoolSize thread가 Busy 상태에 있는 경우에 새로운 태스크가 큐에 넣어진다. 이 때문에 corePoolSize를 넘는 thread는 작성되지 않는다 (따라서, maximumPoolSize 값은 영향을 미치지 않는다). 이것이 적절한 것은 Web 페이지 서버내 등, 각 태스크가 다른 태스크로부터 완전하게 독립하고 있기 위해서 태스크가 다른 태스크의 실행에 영향을 미치는 것이 없는 경우이다. 이 큐 스타일은 일시적으로 급증한 요구를 처리하는 경우 등에 유용하지만, 전체적으로 처리 능력을 넘는 속도로 커멘드가 차례차례로 도착하면, 안 바운드 형식의 작업 큐가 커질 가능성이 있다
3. 바운드 형식의 큐. 바운드 형식의 큐 (ArrayBlockingQueue 등)는 한정된 maximumPoolSizes와 함께 사용하면 자원의 고갈을 막는 경우에 도움이 되지만, 튜닝이나 제어가 곤란하게 될 가능성이 있다. 큐 사이즈와 최대 풀 사이즈는 트레이드 오프의 관계에 있다. 대규모 큐와 소규모의 풀을 사용하면, CPU 사용, OS 자원 및 컨텍스트 변환의 오버헤드를 가능한 한 줄일 수가 있지만, 그 때문에(위해) throughput가 저하할 가능성이 있다. 태스크가 빈번하게 블록 하는 (예를 들어 입출력이 제한된다) 경우, 다른 방법으로 허가하는 것보다도 많은 thread에 대해서 시스템이 시간을 스케줄 할 수 있다. 보통, 소규모의 큐를 사용하면, 대량의 풀 사이즈가 필요하게 된다. 이것에 의해 CPU Busy 상태가 많아지지만, 수락 불가의 스케줄링 오버헤드에 조우할 가능성이 있기 때문에 역시 throughput가 저하한다

거부된 태스크

Executor가 셧다운 하고 있는 경우 및 Executor가 최대 thread와 작업 큐 용량의 양쪽 모두를 제한해, 그것이 포화 상태에 있는 경우, execute(java.lang.Runnable) 메서드내에 송신된 새로운 태스크는 「거부」됩니다. 어느 쪽의 경우도, execute 메서드는 RejectedExecutionHandler RejectedExecutionHandler.rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor) 메서드를 호출합니다. 다음의 4개의 정의가 끝난 핸들러 정책가 제공됩니다.

1. 디폴트 ThreadPoolExecutor.AbortPolicy 에서는 거부되면, 핸들러는 실행시 RejectedExecutionException를 Throw 한다
2. ThreadPoolExecutor.CallerRunsPolicy 에서는 execute 자체를 호출하는 thread가 태스크를 실행한다. 이것에 의해 단순한 피드백 제어 메카니즘이 제공되어 결과적으로 새로운 태스크의 송신 레이트가 저하한다
3. ThreadPoolExecutor.DiscardPolicy 에서는 실행 불가능한 태스크는 단지 삭제된다
4. ThreadPoolExecutor.DiscardOldestPolicy 에서는 executor가 셧다운 하고 있지 않는 경우, 작업 큐의 선두에 있는 태스크가 삭제되어 실행이 재차 시도된다 (재차 실패할 가능성도 있어, 그 경우는 이것이 반복해진다)

다른 종류 RejectedExecutionHandler 클래스를 정의 및 사용하는 일도 가능합니다. 이 경우 특히 정책가 특정의 용량 또는 큐잉 정책에 서만 동작하도록 설계되고 있는 경우는 주의가 필요합니다.

훅 메서드

이 클래스는 protected를 오버라이드(override) 가능한 beforeExecute(java.lang.Thread, java.lang.Runnable) 및 afterExecute(java.lang.Runnable, java.lang.Throwable) 메서드를 제공합니다. 이것은 각 태스크의 실행 전후에 호출합니다. 이것들은 ThreadLocals 재초기화, 통계의 수집, 로그 엔트리의 추가등의, 실행 환경의 조작에 사용할 수 있습니다. 또한, terminated() 메서드를 오버라이드(override) 해, Executor가 완전하게 종료한 후에 실행할 필요가 있는 특수한 처리를 실행할 수 있습니다.

훅 메서드 또는 콜백 메서드가 예외를 Throw 하면, 내부의 워카스레드가 실패해 즉시 종료합니다.

큐의 보수

getQueue() 메서드를 사용하면, 감시 및 디버그 목적으로 작업 큐에 액세스 할 수 있습니다. 다른 목적으로 이 메서드를 사용하는 것은 가능한 한 피해 주세요. 큐에 넣어진 대량의 태스크가 삭제되었을 경우, 제공되는 2개의 메서드 remove(java.lang.Runnable) 및 purge()를 기억 영역의 재원시지원에 사용할 수 있습니다.

확장 기능의 예. 이 클래스의 확장 기능의 대부분은 1개 이상의 protected 훅 메서드를 오버라이드(override) 합니다. 다음의 예는 단순한 일시정지/재개 기능을 추가하는 서브 클래스입니다.

 class PausableThreadPoolExecutor extends ThreadPoolExecutor {
   private boolean isPaused;
   private ReentrantLock pauseLock = new ReentrantLock();
   private Condition unpaused = pauseLock.newCondition();

   public PausableThreadPoolExecutor(...) { super(...); }
 
   protected void beforeExecute(Thread t, Runnable r) {
     super.beforeExecute(t, r);
     pauseLock.lock();
     try {
       while (isPaused) unpaused.await();
     } catch(InterruptedException ie) {
       t.interrupt();
     } finally {
       pauseLock.unlock();
     }
   }
 
   public void pause() {
     pauseLock.lock();
     try {
       isPaused = true;
     } finally {
       pauseLock.unlock();
     }
   }
 
   public void resume() {
     pauseLock.lock();
     try {
       isPaused = false;
       unpaused.signalAll();
     } finally {
       pauseLock.unlock();
     }
   }
 }
 

도입된 버전 :

1.5

중첩(Nested) 클래스 개요

static class	ThreadPoolExecutor.AbortPolicy RejectedExecutionException을 Throw 한다, 거부된 태스크의 핸들러.
static class	ThreadPoolExecutor.CallerRunsPolicy executor가 셧다운 하고 있지 않는 경우에 execute 메서드의 thread 호출로 거부된 태스크를 직접 실행한다, 거부된 태스크의 핸들러.
static class	ThreadPoolExecutor.DiscardOldestPolicy executor가 셧다운 하고 있지 않는 경우에 가장 낡은 미처리의 요구를 파기해 execute를 재시행한다, 거부된 태스크의 핸들러.
static class	ThreadPoolExecutor.DiscardPolicy 거부된 태스크를 예고 없이 파기한다, 거부된 태스크의 핸들러.

생성자 개요

ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue <Runnable > workQueue)
지정된 초기 파라미터 및 디폴트의 thread 팩토리 및 핸들러를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue <Runnable > workQueue, RejectedExecutionHandler handler)
지정된 초기 파라미터를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue <Runnable > workQueue, ThreadFactory threadFactory)
지정된 초기 파라미터를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

ThreadPoolExecutor (int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue <Runnable > workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
지정된 초기 파라미터를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

메서드 개요

protected void	afterExecute (Runnable r, Throwable t) 지정된 Runnable 실행 완료시에 호출되는 메서드.
boolean	awaitTermination (long timeout, TimeUnit unit) 셧다운 요구 후에 모든 태스크가 실행을 완료하는 타임 아웃이 발생하는 현재의 thread로 인터럽트가 발생하는 어떤 것인가가 최초로 일어날 때까지 블록 합니다.
protected void	beforeExecute (Thread t, Runnable r) 지정된 thread내에서 지정된 Runnable 실행에 앞서 호출되는 메서드.
void	execute (Runnable command) 지정된 태스크를 장래의 언젠가 실행합니다.
protected void	finalize () 이 executor가 참조되는 것이 없어졌을 경우에 shutdown를 호출합니다.
int	getActiveCount () 태스크를 활성화 실행중의 thread의 개수를 리턴합니다.
long	getCompletedTaskCount () 실행이 완료한 태스크의 대체로의 총수를 리턴합니다.
int	getCorePoolSize () thread의 코어수를 리턴합니다.
long	getKeepAliveTime (TimeUnit unit) thread의 킵얼라이브 시간을 리턴합니다.
int	getLargestPoolSize () 지금까지 동시에 풀에 존재한 thread의 최대수를 리턴합니다.
int	getMaximumPoolSize () 허가되는 thread의 최대수를 리턴합니다.
int	getPoolSize () 풀내의 현재의 thread수를 리턴합니다.
BlockingQueue <Runnable >	getQueue () 이 executor가 사용하는 태스크 큐를 리턴합니다.
RejectedExecutionHandler	getRejectedExecutionHandler () 실행 불가능한 태스크용의 현재의 핸들러를 리턴합니다.
long	getTaskCount () 실행이 스케줄 된 태스크의 대체로의 총수를 리턴합니다.
ThreadFactory	getThreadFactory () 새로운 thread의 작성에 사용하는 thread 팩토리를 리턴합니다.
boolean	isShutdown () 이 executor가 셧다운 했을 경우, true를 리턴합니다.
boolean	isTerminated () 셧다운에 이어 모든 태스크가 완료했을 경우에 true를 리턴합니다.
boolean	isTerminating () shutdown 또는 shutdownNow 후에 이 executor가 종료 처리를 실행중이지만, 완전하게 종료하고 있지 않는 경우, true를 리턴합니다.
int	prestartAllCoreThreads () 모든 코어 thread를 개시해,자식 돌 상태로 대기시킵니다.
boolean	prestartCoreThread () 코어 thread를 개시해,자식 돌 상태로 대기시킵니다.
void	purge () 작업 큐로부터 삭제된 Future 태스크 모든 삭제를 시도합니다.
boolean	remove (Runnable task) 이 태스크가 존재하는 경우, executor 내부 큐로부터 삭제해, 아직 시작하고 있지 않으면 실행되지 않게 합니다.
void	setCorePoolSize (int corePoolSize) thread의 코어수를 설정합니다.
void	setKeepAliveTime (long time, TimeUnit unit) thread가 종료하기 전에 자식 돌 상태에 머무르는 제한 시간을 설정합니다.
void	setMaximumPoolSize (int maximumPoolSize) 허가되는 thread의 최대수를 설정합니다.
void	setRejectedExecutionHandler (RejectedExecutionHandler handler) 실행 불가능한 태스크용의 새로운 핸들러를 설정합니다.
void	setThreadFactory (ThreadFactory threadFactory) 새로운 thread의 작성에 사용하는 thread 팩토리를 설정합니다.
void	shutdown () 순서에 따라 실행되는 셧다운을 개시합니다.
List <Runnable >	shutdownNow () 실행중의 활성화된 태스크 모든 정지를 시도해 대기중의 태스크의 처리를 정지해, 실행을 대기하고 있던 태스크의 리스트를 리턴합니다.
protected void	terminated () Executor가 종료되었을 때에 호출되는 메서드.

클래스 java.util.concurrent. AbstractExecutorService 로부터 상속된 메서드

invokeAll, invokeAll, invokeAny, invokeAny, submit, submit, submit

클래스 java.lang. Object 로부터 상속된 메서드

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

생성자 상세

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit  unit,
                          BlockingQueue <Runnable > workQueue)

지정된 초기 파라미터 및 디폴트의 thread 팩토리 및 핸들러를 사용해, 새로운 ThreadPoolExecutor를 작성합니다. 이 범용 생성자를 사용하는 것보다도, Executors 팩토리 메서드의 1개를 사용하는 것이 편리한 경우가 있습니다.

파라미터:

corePoolSize - 풀내 로 유지하는 thread의 수 (아이돌 상태의 thread도 포함한다)

maximumPoolSize - 풀에서 허가되는 thread의 최대수

keepAliveTime - thread의 수가 코어보다 많은 경우, 이것은 초과한자식 돌 상태의 thread가 종료전에 새로운 태스크를 대기하는 최대 시간이 되는

unit - keepAliveTime 인수의 시간 단위

workQueue - 태스크를 실행하기 전에 태스크 보관 유지에 사용하는 큐. 이 큐는 execute 메서드에 의해 송신된 Runnable 태스크만을 보관 유지한다

예외:

IllegalArgumentException - corePoolSize 또는 keepAliveTime가 제로 미만의 경우, maximumPoolSize가 제로 아래의 경우, 또는 corePoolSize가 maximumPoolSize 보다 큰 경우

NullPointerException - workQueue가 null인 경우

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit  unit,
                          BlockingQueue <Runnable > workQueue,
                          ThreadFactory  threadFactory)

지정된 초기 파라미터를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

파라미터:

corePoolSize - 풀내 로 유지하는 thread의 수 (아이돌 상태의 thread도 포함한다)

maximumPoolSize - 풀에서 허가되는 thread의 최대수

keepAliveTime - thread의 수가 코어보다 많은 경우, 이것은 초과한자식 돌 상태의 thread가 종료전에 새로운 태스크를 대기하는 최대 시간이 되는

unit - keepAliveTime 인수의 시간 단위

workQueue - 태스크를 실행하기 전에 태스크 보관 유지에 사용하는 큐. 이 큐는 execute 메서드에 의해 송신된 Runnable 태스크만을 보관 유지하는

threadFactory - executor가 새로운 thread를 작성할 때에 사용하는 팩토리

예외:

IllegalArgumentException - corePoolSize 또는 keepAliveTime가 제로 미만의 경우, maximumPoolSize가 제로 아래의 경우, 또는 corePoolSize가 maximumPoolSize 보다 큰 경우

NullPointerException - workQueue 또는 threadFactory가 null인 경우

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit  unit,
                          BlockingQueue <Runnable > workQueue,
                          RejectedExecutionHandler  handler)

지정된 초기 파라미터를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

파라미터:

corePoolSize - 풀내 로 유지하는 thread의 수 (아이돌 상태의 thread도 포함한다)

maximumPoolSize - 풀에서 허가되는 thread의 최대수

keepAliveTime - thread의 수가 코어보다 많은 경우, 이것은 초과한자식 돌 상태의 thread가 종료전에 새로운 태스크를 대기하는 최대 시간이 되는

unit - keepAliveTime 인수의 시간 단위

workQueue - 태스크를 실행하기 전에 태스크 보관 유지에 사용하는 큐. 이 큐는 execute 메서드에 의해 송신된 Runnable 태스크만을 보관 유지하는

handler - thread가 제한에 이르는지, 큐가 용량에 이르렀기 때문에 실행이 블록 되었을 경우에 사용하는 핸들러

예외:

IllegalArgumentException - corePoolSize 또는 keepAliveTime가 제로 미만의 경우, maximumPoolSize가 제로 아래의 경우, 또는 corePoolSize가 maximumPoolSize 보다 큰 경우

NullPointerException - workQueue 또는 handler가 null인 경우

ThreadPoolExecutor

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit  unit,
                          BlockingQueue <Runnable > workQueue,
                          ThreadFactory  threadFactory,
                          RejectedExecutionHandler  handler)

지정된 초기 파라미터를 사용해, 새로운 ThreadPoolExecutor를 작성합니다.

파라미터:

corePoolSize - 풀내 로 유지하는 thread의 수 (아이돌 상태의 thread도 포함한다)

maximumPoolSize - 풀에서 허가되는 thread의 최대수

keepAliveTime - thread의 수가 코어보다 많은 경우, 이것은 초과한자식 돌 상태의 thread가 종료전에 새로운 태스크를 대기하는 최대 시간이 되는

unit - keepAliveTime 인수의 시간 단위

workQueue - 태스크를 실행하기 전에 태스크 보관 유지에 사용하는 큐. 이 큐는 execute 메서드에 의해 송신된 Runnable 태스크만을 보관 유지하는

threadFactory - executor가 새로운 thread를 작성할 때에 사용하는 팩토리

handler - thread가 제한에 이르는지, 큐가 용량에 이르렀기 때문에 실행이 블록 되었을 경우에 사용하는 핸들러

예외:

IllegalArgumentException - corePoolSize 또는 keepAliveTime가 제로 미만의 경우, maximumPoolSize가 제로 아래의 경우, 또는 corePoolSize가 maximumPoolSize 보다 큰 경우

NullPointerException - workQueue, threadFactory, 또는 handler가 null인 경우

메서드의 상세

execute

public void execute(Runnable  command)

지정된 태스크를 장래의 언젠가 실행합니다. 이 태스크는 새로운 thread로 실행되는 일도, 풀 된 기존의 thread로 실행되는 일도 있습니다.이 executor가 셧다운 하고 있는지, 용량이 가득 되었기 때문에 태스크를 실행용으로 송신할 수 없는 경우, 태스크는 현재의 RejectedExecutionHandler에 의해 처리됩니다.

파라미터:

command - 실행하는 태스크

예외:

RejectedExecutionException - 태스크를 실행용으로 받아들일 수가 없는 경우, RejectedExecutionHandler 판단으로 Throw 된다

NullPointerException - 커멘드가 null인 경우

shutdown

public void shutdown()

순서에 따라 실행되는 셧다운을 개시합니다. 이전에 송신된 태스크가 실행됩니다만, 새로운 태스크는 받아들여지지 않습니다. 셧다운 후에 호출을 실행해도, 효과는 없습니다.

예외:

SecurityException - 시큐러티 매니저가 존재하는 상황으로 셧다운을 실행하면, 이 ExecutorService 이 호출해 측에는 변경이 허가되지 않는 thread를 조작할 수 있는 경우. 이것은, RuntimePermission ("modifyThread")를 보관 유지하지 않는지, 시큐러티 매니저의 checkAccess 메서드가 액세스를 거부하기 위해이다

shutdownNow

public List <Runnable > shutdownNow()

실행중의 활성화된 태스크 모든 정지를 시도해 대기중의 태스크의 처리를 정지해, 실행을 대기하고 있던 태스크의 리스트를 리턴합니다.

이 구현은 Thread.interrupt()를 개입시켜 태스크를 취소합니다. 이 때문에 몇개의 태스크가 마스크를 실행하는지, 인터럽트에의 응답에 실패하면, 그 태스크가 결코 종료하지 않게 될 가능성이 있습니다.

반환값:

실행이 개시되지 않았던 태스크의 리스트

예외:

SecurityException - 시큐러티 매니저가 존재하는 상황으로 셧다운을 실행하면, 이 ExecutorService 이 호출해 측에는 변경이 허가되지 않는 thread를 조작할 수 있는 경우. 이것은, RuntimePermission ("modifyThread")를 보관 유지하지 않는지, 시큐러티 매니저의 checkAccess 메서드가 액세스를 거부하기 위해이다

isShutdown

public boolean isShutdown()

인터페이스 ExecutorService 기술:

이 executor가 셧다운 했을 경우, true를 리턴합니다.

반환값:

이 executor가 셧다운 했을 경우는 true

isTerminating

public boolean isTerminating()

shutdown 또는 shutdownNow 후에 이 executor가 종료 처리를 실행중이지만, 완전하게 종료하고 있지 않는 경우, true를 리턴합니다. 이 메서드는 디버그로 유용한 경우가 있습니다. 셧다운 후, 충분한 시간이 경과하고 나서 true가 돌려주고졌을 경우, 송신된 태스크가 인터럽트를 무시했는지 억제했기 때문에 이 executor가 적정하게 종료하고 있지 않을 가능성이 있습니다.

반환값:

종료중이지만, 완료하고 있지 않는 경우는 true

isTerminated

public boolean isTerminated()

인터페이스 ExecutorService 기술:

셧다운에 이어 모든 태스크가 완료했을 경우에 true를 리턴합니다. shutdown 또는 shutdownNow가 최초로 불려가 지 않는 한, isTerminated는 결코 true로는 되지 않습니다.

반환값:

셧다운에 이어 모든 태스크가 완료했을 경우에 true

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit  unit)
                         throws InterruptedException 

인터페이스 ExecutorService 기술:

셧다운 요구 후에 모든 태스크가 실행을 완료하는 타임 아웃이 발생하는 현재의 thread로 인터럽트가 발생하는 어떤 것인가가 최초로 일어날 때까지 블록 합니다.

파라미터:

timeout - 대기하는 최장 시간

unit - timeout 인수의 시간 단위

반환값:

이 executor가 종료되는 경우는 true, 종료전에 타임 아웃이 경과했을 경우는 false

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우

finalize

protected void finalize()

이 executor가 참조되는 것이 없어졌을 경우에 shutdown를 호출합니다.

오버라이드(override):

클래스 Object 내의 finalize

setThreadFactory

public void setThreadFactory(ThreadFactory  threadFactory)

새로운 thread의 작성에 사용하는 thread 팩토리를 설정합니다.

파라미터:

threadFactory - 새로운 thread 팩토리

예외:

NullPointerException - threadFactory가 null인 경우

관련 항목:

getThreadFactory()

getThreadFactory

public ThreadFactory  getThreadFactory()

새로운 thread의 작성에 사용하는 thread 팩토리를 리턴합니다.

반환값:

현재의 thread 팩토리

관련 항목:

setThreadFactory(java.util.concurrent.ThreadFactory)

setRejectedExecutionHandler

public void setRejectedExecutionHandler(RejectedExecutionHandler  handler)

실행 불가능한 태스크용의 새로운 핸들러를 설정합니다.

파라미터:

handler - 새로운 핸들러

예외:

NullPointerException - 핸들러가 null인 경우

관련 항목:

getRejectedExecutionHandler()

getRejectedExecutionHandler

public RejectedExecutionHandler  getRejectedExecutionHandler()

실행 불가능한 태스크용의 현재의 핸들러를 리턴합니다.

반환값:

현재의 핸들러

관련 항목:

setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)

getQueue

public BlockingQueue <Runnable > getQueue()

이 executor가 사용하는 태스크 큐를 리턴합니다. 태스크 큐에의 액세스는 주로 디버그 및 감시로 사용합니다. 이 큐는 활성화 사용되고 있을 가능성이 있습니다. 태스크 큐의 취득에의해 큐에 넣어진 태스크의 실행을 방해할 수 있을 것은 없습니다.

반환값:

태스크 큐

remove

public boolean remove(Runnable  task)

이 태스크가 존재하는 경우, executor 내부 큐로부터 삭제해, 아직 시작하고 있지 않으면 실행되지 않게 합니다.

이 메서드는 취소 schema의 일부로서 유효하게 사용할 수 있습니다. 내부 큐에 배치되기 전에 다른 형식에 변환된 태스크는 삭제에 실패하는 경우가 있습니다. 예를 들어, submit를 사용해 입력된 태스크는 Future 상태를 유지하는 형식에 변환될 가능성이 있습니다. 다만, 이 경우는 purge() 메서드를 사용해 이러한 삭제된 Future를 삭제할 수 있습니다.

파라미터:

task - 삭제하는 태스크

반환값:

태스크가 삭제되었을 경우는 true

purge

public void purge()

작업 큐로부터 삭제된 Future 태스크 모든 삭제를 시도합니다. 이 메서드는 기능에 다른 영향을 미칠리가 없는 기억 영역의 재생 조작에 도움이 됩니다. 삭제된 태스크는 결코 실행됩니다만, 워카스레드가 이것들을 활성화 삭제할 수 있게 될 때까지 작업 큐에 축적됩니다. 이 메서드를 호출하면, 그러한 삭제를 즉시 시도합니다. 다만, 다른 thread로부터의 간섭이 존재하는 경우, 이 메서드는 태스크의 삭제에 실패할 가능성이 있습니다.

setCorePoolSize

public void setCorePoolSize(int corePoolSize)

thread의 코어수를 설정합니다. 이것은 생성자 으로 설정된 값을 모두 오버라이드(override) 합니다. 새로운 값이 현재의 값보다 작은 경우, 초과하고 있는 기존의 thread는자식 돌 상태가 되면 종료합니다. 새로운 값이 현재의 값보다 큰 경우, 필요에 따라서 새로운 thread가 시작되어 큐에 넣어진 모든 태스크가 실행됩니다.

파라미터:

corePoolSize - 새로운 코어 사이즈

예외:

IllegalArgumentException - corePoolSize가 제로 미만의 경우

관련 항목:

getCorePoolSize()

getCorePoolSize

public int getCorePoolSize()

thread의 코어수를 리턴합니다.

반환값:

thread의 코어수

관련 항목:

setCorePoolSize(int)

prestartCoreThread

public boolean prestartCoreThread()

코어 thread를 개시해,자식 돌 상태로 대기시킵니다. 이것은 새로운 태스크가 실행되는 경우에게만, 코어 thread 개시의 디폴트 정책를 오버라이드(override) 합니다. 모든 코어 thread가 이미 개시되고 있는 경우, 이 메서드는 false를 리턴합니다.

반환값:

thread가 개시되고 있었을 경우는 true

prestartAllCoreThreads

public int prestartAllCoreThreads()

모든 코어 thread를 개시해,자식 돌 상태로 대기시킵니다. 이것은 새로운 태스크의 실행시에게만, 코어 thread 개시의 디폴트 정책를 오버라이드(override) 합니다.

반환값:

개시된 thread의 수

setMaximumPoolSize

public void setMaximumPoolSize(int maximumPoolSize)

허가되는 thread의 최대수를 설정합니다. 이것은 생성자내에서 설정된 모든 값을 오버라이드(override) 합니다. 새로운 값이 현재의 값보다 작은 경우, 초과한 기존의 thread는 다음에 자식 돌 상태가 되면 종료합니다.

파라미터:

maximumPoolSize - 새로운 최대값

예외:

IllegalArgumentException - maximumPoolSize가 제로 미만 또는코어 풀 사이즈인 경우

관련 항목:

getMaximumPoolSize()

getMaximumPoolSize

public int getMaximumPoolSize()

허가되는 thread의 최대수를 리턴합니다.

반환값:

허가되는 thread의 최대수

관련 항목:

setMaximumPoolSize(int)

setKeepAliveTime

public void setKeepAliveTime(long time,
                             TimeUnit  unit)

thread가 종료하기 전에 자식 돌 상태에 머무르는 제한 시간을 설정합니다. 현재 풀내에 있는 thread의 코어수보다 thread가 많은 경우, 이 기간만 태스크를 처리하지 않고 대기한 후에 초과한 thread가 종료합니다. 이것은 생성자 으로 설정된 모든 값을 오버라이드(override) 합니다.

파라미터:

time - 대기 시간. 시간값이 제로의 경우, 초과한 thread는 태스크의 실행 후 즉시 종료하는

unit - time 인수의 시간 단위

예외:

IllegalArgumentException - 시간이 제로 미만의 경우

관련 항목:

getKeepAliveTime(java.util.concurrent.TimeUnit)

getKeepAliveTime

public long getKeepAliveTime(TimeUnit  unit)

thread의 킵얼라이브 시간을 리턴합니다. 이것은 코어 풀 사이즈를 초과한 thread가 종료하기 전에 자식 돌 상태에 머무르는 기간입니다.

파라미터:

unit - 기대되는 결과의 시간 단위

반환값:

제한 시간

관련 항목:

setKeepAliveTime(long, java.util.concurrent.TimeUnit)

getPoolSize

public int getPoolSize()

풀내의 현재의 thread수를 리턴합니다.

반환값:

thread의 수

getActiveCount

public int getActiveCount()

태스크를 활성화 실행중의 thread의 개수를 리턴합니다.

반환값:

thread의 수

getLargestPoolSize

public int getLargestPoolSize()

지금까지 동시에 풀에 존재한 thread의 최대수를 리턴합니다.

반환값:

thread의 수

getTaskCount

public long getTaskCount()

실행이 스케줄 된 태스크의 대체로의 총수를 리턴합니다. 태스크 및 thread 상태는 계산중에 동적으로 변화할 가능성이 있기 때문에 리턴된 값은 개산에 지나지 않습니다만, 일련의 호출을 통해서 감소할 것은 없습니다.

반환값:

태스크의 수

getCompletedTaskCount

public long getCompletedTaskCount()

실행이 완료한 태스크의 대체로의 총수를 리턴합니다. 태스크 및 thread 상태는 계산중에 동적으로 변화할 가능성이 있기 때문에 리턴된 값은 개산에 지나지 않습니다만, 일련의 호출을 통해서 감소할 것은 없습니다.

반환값:

태스크의 수

beforeExecute

protected void beforeExecute(Thread  t,
                             Runnable  r)

지정된 thread내에서 지정된 Runnable 실행에 앞서 호출되는 메서드. 이 메서드는 태스크 r를 실행하는 thread t에 의해 불려가 ThreadLocals 재초기화나 로그의 실행에 사용할 수 있습니다. 주: 복수의 오버라이드(override)를 적정하게 상자로 하기 때문에 보통, 서브 클래스는 이 메서드의 마지막에 super.beforeExecute를 호출할 필요가 있습니다.

파라미터:

t - 태스크 r를 실행하는 thread

r - 실행되는 태스크

afterExecute

protected void afterExecute(Runnable  r,
                            Throwable  t)

지정된 Runnable 실행 완료시에 호출되는 메서드. 이 메서드는 태스크를 실행한 thread에 의해 호출합니다. null 이외의 경우, Throwable는 실행을 갑자기에 종료시킨 캐치 되지 않는 예외입니다. 주: 복수의 오버라이드(override)를 적절히 상자로 하기 때문에 보통, 서브 클래스는 이 메서드의 최초로 super.afterExecute를 호출할 필요가 있습니다.

파라미터:

r - 완료한 runnable

t - 종료의 원인이 된 예외. 실행이 정상적으로 완료했을 경우는 null

terminated

protected void terminated()

Executor가 종료되었을 때에 호출되는 메서드. 디폴트 구현은 아무것도 실행하지 않습니다. 주: 복수의 오버라이드(override)를 적정하게 상자로 하기 때문에 보통, 서브 클래스는 이 메서드내에서 super.terminated를 호출할 필요가 있습니다.