java.util.concurrent
인터페이스 ExecutorService

모든 슈퍼 인터페이스:

Executor

알려진 서브 인터페이스 목록 :

ScheduledExecutorService

알려진 구현 클래스 목록:

AbstractExecutorService, ScheduledThreadPoolExecutor, ThreadPoolExecutor

public interface ExecutorService
extends Executor 

종료를 관리하는 메서드 및 1개 이상의 비동기 태스크의 진행 상황을 추적하는 Future를 생성 가능한 메서드를 제공하는 Executor .

ExecutorService는 새로운 태스크의 수락을 정지하는 셧다운이 가능합니다. 셧다운 하면 executor는 최종적으로 종료합니다만, 그 시점에서는 실행중의 활성화된 태스크나 실행을 대기중의 태스크는 존재하지 않고, 새로운 태스크를 송신할 수도 있습니다.

submit 메서드는 실행의 취소나 완료의 대기에 사용할 수 있는 Future를 작성해 돌려주는 것으로 기저 메서드 Executor.execute(java.lang.Runnable)를 확장합니다. invokeAny 및 invokeAll 메서드는 보통 편리성의 가장 높은 형식의 일괄 실행을 실시해, 태스크의 컬렉션을 실행해, 1개 이상 또는 모든 것이 완료하는 것을 대기합니다. ExecutorCompletionService 클래스를, 이러한 메서드의 커스터마이즈 된 변형의 출력에 사용할 수 있습니다.

Executors 클래스는 이 패키지로 제공되는 executor 서비스용의 팩토리 메서드를 제공합니다.

사용예

다음에 나타내는 네트워크 서비스의 개략에서는 요구가 착신하는 thread 풀 서비스내의 thread를 나타냅니다. 이것은 구성 끝난 Executors.newFixedThreadPool(int) 팩토리 메서드를 사용합니다.

 class NetworkService {
    private final ServerSocket serverSocket;
    private final ExecutorService pool;

    public NetworkService(int port, int poolSize) throws IOException {
      serverSocket = new ServerSocket(port);
      pool = Executors.newFixedThreadPool(poolSize);
    }
 
    public void serve() {
      try {
        for (;;) {
          pool.execute(new Handler(serverSocket.accept()));
        }
      } catch (IOException ex) {
        pool.shutdown();
      }
    }
  }

  class Handler implements Runnable {
    private final Socket socket;
    Handler(Socket socket) { this.socket = socket; }
    public void run() {
      // read and service request
    }
 }
 

도입된 버전 :

1.5

메서드 개요

boolean	awaitTermination (long timeout, TimeUnit unit) 셧다운 요구 후에 모든 태스크가 실행을 완료하는 타임 아웃이 발생하는 현재의 thread로 인터럽트가 발생하는 어떤 것인가가 최초로 일어날 때까지 블록 합니다.
<T> List <Future <T>>	invokeAll (Collection <Callable <T>> tasks) 지정된 태스크를 실행해, Future 리스트를 스테이터스와 함께 돌려주고, 모든 것이 완료하면 결과를 리턴합니다.
<T> List <Future <T>>	invokeAll (Collection <Callable <T>> tasks, long timeout, TimeUnit unit) 지정된 태스크를 실행해, Future 리스트를 스테이터스와 함께 돌려주고, 모든 것이 완료하든가 또는 마감 시간이 될까의 언젠가 빠른 시점에서 결과를 리턴합니다.
<T> T	invokeAny (Collection <Callable <T>> tasks) 지정된 태스크를 실행해, 정상적으로 완료한 태스크가 존재하는 경우는 그 결과를 (예외를 Throw 하지 않고 ) 리턴합니다.
<T> T	invokeAny (Collection <Callable <T>> tasks, long timeout, TimeUnit unit) 지정된 태스크를 실행해, 타임 아웃이 되기 전에 정상적으로 완료한 태스크가 존재하는 경우는 그 결과를 (예외를 Throw 하지 않고 ) 리턴합니다.
boolean	isShutdown () 이 executor가 셧다운 했을 경우, true를 리턴합니다.
boolean	isTerminated () 셧다운에 이어 모든 태스크가 완료했을 경우에 true를 리턴합니다.
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. Executor 로부터 상속된 메서드

execute

메서드의 상세

shutdown

void shutdown()

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

예외:

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

shutdownNow

List <Runnable > shutdownNow()

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

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

반환값:

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

예외:

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

isShutdown

boolean isShutdown()

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

반환값:

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

isTerminated

boolean isTerminated()

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

반환값:

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

awaitTermination

boolean awaitTermination(long timeout,
                         TimeUnit  unit)
                         throws InterruptedException 

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

파라미터:

timeout - 대기하는 최장 시간

unit - timeout 인수의 시간 단위

반환값:

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

예외:

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

submit

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

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

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

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

파라미터:

task - 송신하는 태스크

반환값:

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

예외:

RejectedExecutionException - 태스크의 실행을 스케줄 할 수 없는 경우

NullPointerException - 태스크가 null인 경우

submit

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

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

파라미터:

task - 송신하는 태스크

result - 돌려주는 결과

반환값:

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

예외:

RejectedExecutionException - 태스크의 실행을 스케줄 할 수 없는 경우

NullPointerException - 태스크가 null인 경우

submit

Future <? > submit(Runnable  task)

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

파라미터:

task - 송신하는 태스크

반환값:

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

예외:

RejectedExecutionException - 태스크의 실행을 스케줄 할 수 없는 경우

NullPointerException - 태스크가 null인 경우

invokeAll

<T> List <Future <T>> invokeAll(Collection <Callable <T>> tasks)
                          throws InterruptedException 

지정된 태스크를 실행해, Future 리스트를 스테이터스와 함께 돌려주고, 모든 것이 완료하면 결과를 리턴합니다. 리턴된 리스트의 각 요소에 대해서 Done는 true가 됩니다. 「완료했다」태스크는 보통 의 방법 또는 예외를 Throw 하는 것으로 종료하고 있습니다. 이 조작의 진행중으로 지정된 컬렉션이 변경되었을 경우, 이 메서드의 결과는 정의되지 않습니다.

파라미터:

tasks - 태스크의 컬렉션

반환값:

태스크를 나타내는 Futures 리스트. 리스트의 차례는 지정된 태스크 리스트의 반복자에 의해 생성되는 차례와 같고, 각 태스크는 완료필이다

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우. 이 경우 미완료의 태스크는 삭제된다

NullPointerException - 태스크 또는 그 몇개의 요소가 null인 경우

RejectedExecutionException - 몇개의 태스크의 실행을 스케줄 할 수 없는 경우

invokeAll

<T> List <Future <T>> invokeAll(Collection <Callable <T>> tasks,
                              long timeout,
                              TimeUnit  unit)
                          throws InterruptedException 

지정된 태스크를 실행해, Future 리스트를 스테이터스와 함께 돌려주고, 모든 것이 완료하든가 또는 마감 시간이 될까의 언젠가 빠른 시점에서 결과를 리턴합니다. 리턴된 리스트의 각 요소에 대해서 Done는 true가 됩니다. 리턴된 시점에서는 완료하고 있지 않는 태스크는 삭제됩니다. 「완료했다」태스크는 보통 의 방법 또는 예외를 Throw 하는 것으로 종료하고 있습니다. 이 조작의 진행중으로 지정된 컬렉션이 변경되었을 경우, 이 메서드의 결과는 정의되지 않습니다.

파라미터:

tasks - 태스크의 컬렉션

timeout - 대기하는 최장 시간

unit - timeout 인수의 시간 단위

반환값:

태스크를 나타내는 Futures 리스트. 리스트의 차례는 지정된 태스크 리스트의 반복자에 의해 생성되는 차례와 같게 된다. 조작이 타임 아웃 하지 않았던 경우, 각 태스크는 완료한다. 타임 아웃 했을 경우는 태스크의 일부는 완료하지 않는다

예외:

InterruptedException - 대기중에 인터럽트가 발생했을 경우. 이 경우 미완료의 태스크는 삭제된다

NullPointerException - 태스크, 그 요소의 언젠가 또는 단위가 null인 경우

RejectedExecutionException - 몇개의 태스크의 실행을 스케줄 할 수 없는 경우

invokeAny

<T> T invokeAny(Collection <Callable <T>> tasks)
            throws InterruptedException,

                   ExecutionException 

지정된 태스크를 실행해, 정상적으로 완료한 태스크가 존재하는 경우는 그 결과를 (예외를 Throw 하지 않고 ) 리턴합니다. 보통 또는 예외를 수반하는 복귀시에 미완료의 태스크는 삭제됩니다. 이 조작이 진행중으로 지정된 컬렉션이 변경되었을 경우의, 이 메서드의 결과는 정의되지 않습니다.

파라미터:

tasks - 태스크의 컬렉션

반환값:

몇개의 태스크에 의해 리턴된 결과

예외:

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

NullPointerException - 태스크 또는 그 몇개의 요소가 null인 경우

IllegalArgumentException - 태스크가 비어있는 경우

ExecutionException - 정상적으로 완료한 태스크가 존재하지 않는 경우

RejectedExecutionException - 태스크의 실행을 스케줄 할 수 없는 경우

invokeAny

<T> T invokeAny(Collection <Callable <T>> tasks,
                long timeout,
                TimeUnit  unit)
            throws InterruptedException,

                   ExecutionException,

                   TimeoutException 

지정된 태스크를 실행해, 타임 아웃이 되기 전에 정상적으로 완료한 태스크가 존재하는 경우는 그 결과를 (예외를 Throw 하지 않고 ) 리턴합니다. 보통 또는 예외를 수반하는 복귀시에 미완료의 태스크는 삭제됩니다. 이 조작이 진행중으로 지정된 컬렉션이 변경되었을 경우의, 이 메서드의 결과는 정의되지 않습니다.

파라미터:

tasks - 태스크의 컬렉션

timeout - 대기하는 최장 시간

unit - timeout 인수의 시간 단위

반환값:

몇개의 태스크에 의해 리턴된 결과

예외:

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

NullPointerException - 태스크, 그 요소의 언젠가 또는 단위가 null인 경우

TimeoutException - 몇개의 태스크가 정상적으로 완료하기 전에 지정된 타임 아웃 시간이 경과했을 경우

ExecutionException - 정상적으로 완료한 태스크가 존재하지 않는 경우

RejectedExecutionException - 태스크의 실행을 스케줄 할 수 없는 경우