java.util.concurrent
클래스 ScheduledThreadPoolExecutor

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

모든 구현된 인터페이스:

Executor, ExecutorService, ScheduledExecutorService

public class ScheduledThreadPoolExecutor
extends ThreadPoolExecutor 
implements ScheduledExecutorService 

지정된 지연 후 또는 주기적으로 실행하기 위한 커멘드를 추가 스케줄 가능한 ThreadPoolExecutor . 복수의 워크스 레드를 필요로 하는 경우나, ThreadPoolExecutor (이 클래스를 확장한다)의 제공하는 유연성이나 기능이 필요한 경우, 이 클래스를 Timer 보다 우선해 사용합니다.

지연 태스크는 그것이 유효하게 되는 대로 실행됩니다만, 유효하게 된 후 언제 개시될까에 관해서 리얼타임의 보증은 없습니다. 실행 시간이 정확하게 같게 스케줄 된 태스크는 선입처 방편 (FIFO)의 송신순서에 유효하게 됩니다.

이 클래스는 ThreadPoolExecutor 로부터 상속됩니다만, 상속한 튜닝 메서드의 몇개인가는 유용하지는 않습니다. 특히, corePoolSize thread 및 안 바운드 형식의 큐를 사용하는 고정 사이즈의 풀로서 동작하기 위해, maximumPoolSize를 조정해도 유익한 결과는 얻을 수 있지 않습니다.

도입된 버전 :

1.5

중첩(Nested) 클래스 개요

클래스 java.util.concurrent. ThreadPoolExecutor 로부터 상속된 중첩(Nested) 클래스/인터페이스

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

생성자 개요

ScheduledThreadPoolExecutor (int corePoolSize)
지정한 코어 풀 사이즈로 새로운 ScheduledThreadPoolExecutor를 작성합니다.

ScheduledThreadPoolExecutor (int corePoolSize, RejectedExecutionHandler handler)
지정된 초기 파라미터를 사용해, 새로운 ScheduledThreadPoolExecutor를 작성합니다.

ScheduledThreadPoolExecutor (int corePoolSize, ThreadFactory threadFactory)
지정된 초기 파라미터를 사용해, 새로운 ScheduledThreadPoolExecutor를 작성합니다.

ScheduledThreadPoolExecutor (int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)
지정된 초기 파라미터를 사용해, 새로운 ScheduledThreadPoolExecutor를 작성합니다.

메서드 개요

void	execute (Runnable command) 제로의 지연 요구로 커멘드를 실행합니다.
boolean	getContinueExistingPeriodicTasksAfterShutdownPolicy () 이 executor 로 shutdown가 실행되었을 경우에서도 기존의 주기 태스크의 실행을 계속할지 어떨지에 관한 정책를 취득합니다.
boolean	getExecuteExistingDelayedTasksAfterShutdownPolicy () 이 executor 로 shutdown가 실행되었을 경우에서도 기존의 지연 태스크를 실행할지 어떨지에 관한 정책를 취득합니다.
BlockingQueue <Runnable >	getQueue () 이 executor가 사용하는 태스크 큐를 리턴합니다.
boolean	remove (Runnable task) 이 태스크가 존재하는 경우, executor 내부 큐로부터 삭제해, 아직 시작하고 있지 않으면 실행되지 않게 합니다.
<V> ScheduledFuture <V>	schedule (Callable <V> callable, long delay, TimeUnit unit) 지정된 지연 후에 유효하게 되는 ScheduledFuture를 작성 및 실행합니다.
ScheduledFuture <? >	schedule (Runnable command, long delay, TimeUnit unit) 지정된 지연 후에 유효하게 되는 단발적인 액션을 작성 및 실행합니다.
ScheduledFuture <? >	scheduleAtFixedRate (Runnable command, long initialDelay, long period, TimeUnit unit) 지정된 초기 지연 후에 최초로 유효하게 되어, 그 뒤로는 지정된 기간 후에 유효하게 되는 주기적인 액션을 작성 및 실행합니다.
ScheduledFuture <? >	scheduleWithFixedDelay (Runnable command, long initialDelay, long delay, TimeUnit unit) 지정된 초기 지연 후에 최초로 유효하게 되어, 그 뒤로는 실행 종료로부터 다음의 실행 개시까지의 지정 지연 후에 유효하게 되는 주기적인 액션을 작성 및 실행합니다.
void	setContinueExistingPeriodicTasksAfterShutdownPolicy (boolean value) 이 executor 로 shutdown가 실행되었을 경우에서도 기존의 주기 태스크의 실행을 계속할지 어떨지에 관한 정책를 설정합니다.
void	setExecuteExistingDelayedTasksAfterShutdownPolicy (boolean value) 이 executor 로 shutdown가 실행되었을 경우에서도 기존의 지연 태스크를 실행할지 어떨지에 관한 정책를 설정합니다.
void	shutdown () 순서에 따라 실행되는 셧다운을 개시합니다.
List <Runnable >	shutdownNow () 실행중의 활성화된 태스크 모든 정지를 시도해 대기중의 태스크의 처리를 정지해, 실행을 대기하고 있던 태스크의 리스트를 리턴합니다.
<T> Future <T>	submit (Callable <T> task) 값을 돌려주는 실행 태스크를 송신해, 보류중의 태스크 결과를 나타내는 Future를 리턴합니다.
Future <? >	submit (Runnable task) 실행용의 Runnable 태스크를 송신해, 그 태스크를 나타내는 Future를 리턴합니다.
<T> Future <T>	submit (Runnable task, T result) 실행용의 Runnable 태스크를 송신해, 완료시로 지정된 결과를 돌려주는 태스크를 나타내는 Future를 리턴합니다.

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

afterExecute, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated

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

invokeAll, invokeAll, invokeAny, invokeAny

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

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

인터페이스 java.util.concurrent. ExecutorService 로부터 상속된 메서드

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated

생성자 상세

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize)

지정한 코어 풀 사이즈로 새로운 ScheduledThreadPoolExecutor를 작성합니다.

파라미터:

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

예외:

IllegalArgumentException - corePoolSize가 제로 아래의 경우

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                                   ThreadFactory  threadFactory)

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

파라미터:

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

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

예외:

NullPointerException - threadFactory가 null인 경우

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                                   RejectedExecutionHandler  handler)

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

파라미터:

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

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

예외:

NullPointerException - 핸들러가 null인 경우

ScheduledThreadPoolExecutor

public ScheduledThreadPoolExecutor(int corePoolSize,
                                   ThreadFactory  threadFactory,
                                   RejectedExecutionHandler  handler)

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

파라미터:

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

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

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

예외:

NullPointerException - threadFactory 또는 핸들러가 null인 경우

메서드의 상세

remove

public boolean remove(Runnable  task)

클래스 ThreadPoolExecutor 기술:

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

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

오버라이드(override):

클래스 ThreadPoolExecutor 내의 remove

파라미터:

task - 삭제하는 태스크

반환값:

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

schedule

public ScheduledFuture <? > schedule(Runnable  command,
                                   long delay,
                                   TimeUnit  unit)

인터페이스 ScheduledExecutorService 기술:

지정된 지연 후에 유효하게 되는 단발적인 액션을 작성 및 실행합니다.

정의:

인터페이스 ScheduledExecutorService 내의 schedule

파라미터:

command - 실행하는 태스크

delay - 현재부터의 실행 지연 시간

unit - 지연 파라미터의 시간 단위

반환값:

보류 상태의 태스크 완료를 나타내는 Future. 그 get() 메서드는 완료시에 null을 돌려준다

schedule

public <V> ScheduledFuture <V> schedule(Callable <V> callable,
                                       long delay,
                                       TimeUnit  unit)

인터페이스 ScheduledExecutorService 기술:

지정된 지연 후에 유효하게 되는 ScheduledFuture를 작성 및 실행합니다.

정의:

인터페이스 ScheduledExecutorService 내의 schedule

파라미터:

callable - 실행하는 함수

delay - 현재부터의 실행 지연 시간

unit - 지연 파라미터의 시간 단위

반환값:

결과의 추출 또는 취소해에 사용 가능한 ScheduledFuture

scheduleAtFixedRate

public ScheduledFuture <? > scheduleAtFixedRate(Runnable  command,
                                              long initialDelay,
                                              long period,
                                              TimeUnit  unit)

인터페이스 ScheduledExecutorService 기술:

지정된 초기 지연 후에 최초로 유효하게 되어, 그 뒤로는 지정된 기간 후에 유효하게 되는 주기적인 액션을 작성 및 실행합니다. 즉, initialDelay 후에 실행이 시작되어 initialDelay+period 후, initialDelay + 2 * period 후, 라고 하는 상태에 실행되어 갑니다. 몇개의 태스크 실행이 예외에 조우하면, 후속의 실행은 억제됩니다. 그 이외로 태스크가 종료하는 것은 executor가 삭제되는지 종료하는 경우만입니다.

정의:

인터페이스 ScheduledExecutorService 내의 scheduleAtFixedRate

파라미터:

command - 실행하는 태스크

initialDelay - 최초의 실행의 지연 시간

period - 후속의 실행 간격

unit - initialDelay 및 period 파라미터의 시간 단위

반환값:

태스크의 보류 완료를 나타내는 Future. 그 get() 메서드는 취소시에 예외를 Throw 한다

scheduleWithFixedDelay

public ScheduledFuture <? > scheduleWithFixedDelay(Runnable  command,
                                                 long initialDelay,
                                                 long delay,
                                                 TimeUnit  unit)

인터페이스 ScheduledExecutorService 기술:

지정된 초기 지연 후에 최초로 유효하게 되어, 그 뒤로는 실행 종료로부터 다음의 실행 개시까지의 지정 지연 후에 유효하게 되는 주기적인 액션을 작성 및 실행합니다. 몇개의 태스크 실행이 예외에 조우하면, 후속의 실행은 억제됩니다. 그 이외로 태스크가 종료하는 것은 executor가 삭제되는지 종료하는 경우만입니다.

정의:

인터페이스 ScheduledExecutorService 내의 scheduleWithFixedDelay

파라미터:

command - 실행하는 태스크

initialDelay - 최초의 실행의 지연 시간

delay - 실행 종료로부터 다음의 실행 개시까지의 지연

unit - initialDelay 및 delay 파라미터의 시간 단위

반환값:

태스크의 보류 완료를 나타내는 Future. 그 get() 메서드는 취소시에 예외를 Throw 한다

execute

public void execute(Runnable  command)

제로의 지연 요구로 커멘드를 실행합니다. 이것은, schedule(command, 0, anyUnit)와 같은 효과를 얻을 수 있습니다. shutdownNow에 의해 리턴된 큐 및 리스트의 검사에서는 command 자체가 아니고, 지연 제로 ScheduledFuture 에의 액세스를 합니다.

정의:

인터페이스 Executor 내의 execute

오버라이드(override):

클래스 ThreadPoolExecutor 내의 execute

파라미터:

command - 실행하는 태스크

예외:

RejectedExecutionException - executor가 셧다운 했기 때문에 태스크를 받아들여 실행할 수 없는 경우, RejectedExecutionHandler 판단으로 Throw 된다

NullPointerException - 커멘드가 null인 경우

submit

public Future <? > submit(Runnable  task)

인터페이스 ExecutorService 기술:

실행용의 Runnable 태스크를 송신해, 그 태스크를 나타내는 Future를 리턴합니다.

정의:

인터페이스 ExecutorService 내의 submit

오버라이드(override):

클래스 AbstractExecutorService 내의 submit

파라미터:

task - 송신하는 태스크

반환값:

보류 상태의 태스크 완료를 나타내는 Future. 그 get() 메서드는 완료시에 null을 돌려준다

submit

public <T> Future <T> submit(Runnable  task,
                            T result)

인터페이스 ExecutorService 기술:

실행용의 Runnable 태스크를 송신해, 완료시로 지정된 결과를 돌려주는 태스크를 나타내는 Future를 리턴합니다.

정의:

인터페이스 ExecutorService 내의 submit

오버라이드(override):

클래스 AbstractExecutorService 내의 submit

파라미터:

task - 송신하는 태스크

result - 돌려주는 결과

반환값:

태스크의 보류 완료를 나타내는 Future. 그 get() 메서드는 완료시로 지정된 결과를 돌려준다

submit

public <T> Future <T> submit(Callable <T> task)

인터페이스 ExecutorService 기술:

값을 돌려주는 실행 태스크를 송신해, 보류중의 태스크 결과를 나타내는 Future를 리턴합니다.

태스크의 대기를 즉시 블록 하는 경우는 result = exec.submit(aCallable). get(); 형식에서 지정할 수 있습니다.

주: Executors 클래스에는 크로쟈를 닮은 다른 일반 객체를 변환 가능한 메서드 세트 (예를 들어, PrivilegedAction를 송신 가능한 Callable 형식으로 변환할 수 있다)가 포함됩니다.

정의:

인터페이스 ExecutorService 내의 submit

오버라이드(override):

클래스 AbstractExecutorService 내의 submit

파라미터:

task - 송신하는 태스크

반환값:

태스크의 보류 완료를 나타내는 Future

setContinueExistingPeriodicTasksAfterShutdownPolicy

public void setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean value)

이 executor 로 shutdown가 실행되었을 경우에서도 기존의 주기 태스크의 실행을 계속할지 어떨지에 관한 정책를 설정합니다. 이 경우 태스크가 종료하는 것은, shutdownNow 실행시, 또는 셧다운이 완료하고 있는 경우에는 정책를 false로 설정한 뒤 뿐입니다. 이 값의 디폴트는 false 입니다.

파라미터:

value - true인 경우에는 셧다운 후에 속행한다. false인 경우는 속행하지 않는

관련 항목:

getExecuteExistingDelayedTasksAfterShutdownPolicy()

getContinueExistingPeriodicTasksAfterShutdownPolicy

public boolean getContinueExistingPeriodicTasksAfterShutdownPolicy()

이 executor 로 shutdown가 실행되었을 경우에서도 기존의 주기 태스크의 실행을 계속할지 어떨지에 관한 정책를 취득합니다. 이 경우 태스크가 종료하는 것은, shutdownNow 실행시, 또는 셧다운이 완료하고 있는 경우에는 정책를 false로 설정한 뒤 뿐입니다. 이 값의 디폴트는 false 입니다.

반환값:

셧다운 후에 속행하는 경우는 true

관련 항목:

setContinueExistingPeriodicTasksAfterShutdownPolicy(boolean)

setExecuteExistingDelayedTasksAfterShutdownPolicy

public void setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean value)

이 executor 로 shutdown가 실행되었을 경우에서도 기존의 지연 태스크를 실행할지 어떨지에 관한 정책를 설정합니다. 이 경우 태스크가 종료하는 것은, shutdownNow 실행시, 또는 셧다운이 완료하고 있는 경우에는 정책를 false로 설정한 뒤 뿐입니다. 이 값의 디폴트는 false 입니다.

파라미터:

value - true인 경우에는 셧다운 후에 실행합니다. false인 경우는 실행하지 않습니다.

관련 항목:

getExecuteExistingDelayedTasksAfterShutdownPolicy()

getExecuteExistingDelayedTasksAfterShutdownPolicy

public boolean getExecuteExistingDelayedTasksAfterShutdownPolicy()

이 executor 로 shutdown가 실행되었을 경우에서도 기존의 지연 태스크를 실행할지 어떨지에 관한 정책를 취득합니다. 이 경우 태스크가 종료하는 것은, shutdownNow 실행시, 또는 셧다운이 완료하고 있는 경우에는 정책를 false로 설정한 뒤 뿐입니다. 이 값의 디폴트는 false 입니다.

반환값:

셧다운 후에 실행하는 경우는 true

관련 항목:

setExecuteExistingDelayedTasksAfterShutdownPolicy(boolean)

shutdown

public void shutdown()

순서에 따라 실행되는 셧다운을 개시합니다. 이 경우 이전에 송신된 태스크가 실행되어 새로운 태스크는 받아들여지지 않습니다. ExecuteExistingDelayedTasksAfterShutdownPolicy가 false로 설정되면, 기한을 초과하고 있지 않는 기존의 지연 태스크가 삭제됩니다. ContinueExistingPeriodicTasksAfterShutdownPolicy가 true로 설정되면, 기존의 주기 태스크의 장래의 실행이 삭제됩니다.

정의:

인터페이스 ExecutorService 내의 shutdown

오버라이드(override):

클래스 ThreadPoolExecutor 내의 shutdown

shutdownNow

public List <Runnable > shutdownNow()

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

실행중의 활성화된 태스크 처리를 정지하기 위해서 최선의 노력을 하는 것 이상의 보증은 없습니다. 이 구현에서는 Thread.interrupt()를 개입시켜 태스크가 삭제되기 때문에 태스크가 인터럽트에 대한 응답을 마스크 하는지 실패하면, 태스크가 종료하지 않게 될 가능성이 있습니다.

정의:

인터페이스 ExecutorService 내의 shutdownNow

오버라이드(override):

클래스 ThreadPoolExecutor 내의 shutdownNow

반환값:

실행이 결코 개시되지 않는 태스크의 리스트. 이 리스트의 각 요소는 ScheduledFuture 이며, execute를 사용해 송신되는 태스크가 포함된다. 이것들은 지연 제로의 ScheduledFuture 기반으로서 스케줄링으로 사용된다

getQueue

public BlockingQueue <Runnable > getQueue()

이 executor가 사용하는 태스크 큐를 리턴합니다. 이 큐의 각 요소는 ScheduledFuture 이며, execute를 사용해 송신되는 태스크가 포함됩니다. 이것들은 지연 제로의 ScheduledFuture 기반으로서 스케줄링으로 사용됩니다. 이 큐로 사용되는 반복자가 태스크의 실행순서에 태스크를 traversal 하는 것은 보증되지 않습니다.

오버라이드(override):

클래스 ThreadPoolExecutor 내의 getQueue

반환값:

태스크 큐