java.util.concurrent
클래스 ExecutorCompletionService<V>

java.lang.Object 
  java.util.concurrent.ExecutorCompletionService<V>

모든 구현된 인터페이스:

CompletionService <V>

public class ExecutorCompletionService<V>
extends Object 
implements CompletionService <V>

태스크의 실행으로 지정된 Executor를 사용하는 CompletionService . 이 클래스는 송신된 태스크가 완료시에 take를 사용해 액세스 가능한 큐에 배치되도록 준비합니다. 이 클래스는 경량이기 때문에 태스크 그룹을 처리할 때에 일시사용 할 수 있습니다.

사용예 각각이 어떠한 Result 형의 값을 돌려주는 특정의 문제에 대응한 소르바셋트를 보관 유지하고 있어, 이것들을 동시에 실행해, null 이외의 값을 돌려주는 결과를 각각 use(Result r) 메서드로 처리하는 경우를 생각합시다. 다음과 같이 기술할 수 있습니다 .

void solve(Executor e, Collection<Callable<Result>> solvers)
throws InterruptedException, ExecutionException {
CompletionService<Result> ecs = new ExecutorCompletionService<Result>(e);
for (Callable<Result> s : solvers)
ecs.submit(s);
int n = solvers.size();
for (int i = 0; i < n; ++i) {
Result r = ecs.take(). get();
if (r ! = null) 
use(r);
}
}

이번은 예외가 발생한 결과를 제외한, task set의 최초의 null 이외의 결과를 사용하는 경우를 생각합시다. 유효한 최초의 결과를 취득할 수 있으면, 다른 태스크는 모두 취소합니다.

void solve(Executor e, Collection<Callable<Result>> solvers) 
throws InterruptedException {
CompletionService<Result> ecs = new ExecutorCompletionService<Result>(e);
int n = solvers.size();
List<Future<Result>> futures = new ArrayList<Future<Result>>(n);
Result result = null;
try {
for (Callable<Result> s : solvers)
futures.add(ecs.submit(s));
for (int i = 0; i < n; ++i) {
try {
Result r = ecs.take(). get();
if (r ! = null) {
result = r;
break;
}
} catch(ExecutionException ignore) {}
}
}
finally {
for (Future<Result> f : futures)
f.cancel(true);
}

if (result ! = null)
use(result);
}

생성자 개요

ExecutorCompletionService (Executor executor)
기본 태스크의 실행용으로 지정된 executor를 사용해, 완료 큐에 LinkedBlockingQueue를 사용해, ExecutorCompletionService를 작성합니다.

ExecutorCompletionService (Executor executor, BlockingQueue <Future <V >> completionQueue)
기본 태스크의 실행용으로 지정된 executor를 사용해, 완료 큐로 지정된 큐를 사용해, ExecutorCompletionService를 작성합니다.

메서드 개요

Future <V >	poll () 다음의 완료필 태스크를 나타내는 Future를 취득 및 삭제합니다.
Future <V >	poll (long timeout, TimeUnit unit) 다음의 완료필 태스크를 나타내는 Future를 취득 및 삭제합니다.
Future <V >	submit (Callable <V > task) 값을 돌려주는 실행용 태스크를 송신해, 보류 상태의 태스크 결과를 나타내는 Future를 리턴합니다.
Future <V >	submit (Runnable task, V result) 실행하는 Runnable 태스크를 송신해, 그 태스크를 나타내는 Future를 리턴합니다.
Future <V >	take () 다음의 완료필 태스크를 나타내는 Future를 취득 및 삭제합니다.

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

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

생성자 상세

ExecutorCompletionService

public ExecutorCompletionService(Executor  executor)

기본 태스크의 실행용으로 지정된 executor를 사용해, 완료 큐에 LinkedBlockingQueue를 사용해, ExecutorCompletionService를 작성합니다.

파라미터:

executor - 사용하는 executor

예외:

NullPointerException - executor가 null인 경우

ExecutorCompletionService

public ExecutorCompletionService(Executor  executor,
                                 BlockingQueue <Future <V >> completionQueue)

기본 태스크의 실행용으로 지정된 executor를 사용해, 완료 큐로 지정된 큐를 사용해, ExecutorCompletionService를 작성합니다.

파라미터:

executor - 사용하는 executor

completionQueue - 보통, 이 서비스 전용의 완료 큐로서 사용하는 큐

예외:

NullPointerException - executor 또는 completionQueue가 null인 경우

메서드의 상세

submit

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

인터페이스 CompletionService 기술:

값을 돌려주는 실행용 태스크를 송신해, 보류 상태의 태스크 결과를 나타내는 Future를 리턴합니다. 완료시에 이 태스크를 꺼낼까 폴링 할 수 있습니다.

정의:

인터페이스 CompletionService <V > 내의 submit

파라미터:

task - 송신하는 태스크

반환값:

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

submit

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

인터페이스 CompletionService 기술:

실행하는 Runnable 태스크를 송신해, 그 태스크를 나타내는 Future를 리턴합니다. 완료시에 이 태스크를 꺼낼까 폴링 할 수 있습니다.

정의:

인터페이스 CompletionService <V > 내의 submit

파라미터:

task - 송신하는 태스크

result - 정상적으로 완료했을 경우에 돌려주는 결과

반환값:

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

take

public Future <V > take()
               throws InterruptedException 

인터페이스 CompletionService 기술:

다음의 완료필 태스크를 나타내는 Future를 취득 및 삭제합니다. 아무것도 존재하지 않는 경우는 대기합니다.

정의:

인터페이스 CompletionService <V > 내의 take

반환값:

다음의 완료필 태스크를 나타내는 Future

예외:

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

poll

public Future <V > poll()

인터페이스 CompletionService 기술:

다음의 완료필 태스크를 나타내는 Future를 취득 및 삭제합니다. 아무것도 존재하지 않는 경우는 null을 리턴합니다.

정의:

인터페이스 CompletionService <V > 내의 poll

반환값:

다음의 완료필 태스크를 나타내는 Future. 아무것도 존재하지 않는 경우는 null

poll

public Future <V > poll(long timeout,
                      TimeUnit  unit)
               throws InterruptedException 

인터페이스 CompletionService 기술:

다음의 완료필 태스크를 나타내는 Future를 취득 및 삭제합니다. 아무것도 존재하지 않는 경우, 필요에 따라서 지정된 대기 시간까지 대기합니다.

정의:

인터페이스 CompletionService <V > 내의 poll

파라미터:

timeout - 처리를 중지할 때까지의 대기 시간. 단위는 unit

unit - timeout 파라미터의 해석 방법을 지정하는 TimeUnit

반환값:

다음의 완료필 태스크를 나타내는 Future. 지정된 대기 시간이 경과해도 아무것도 존재하지 않는 경우는 null

예외:

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