public class CountingExecutorCompletionService<T> extends ExecutorCompletionService<T>
Constructor and Description |
---|
CountingExecutorCompletionService(Executor executor) |
CountingExecutorCompletionService(Executor executor,
BlockingQueue<Future<T>> completionQueue) |
Modifier and Type | Method and Description |
---|---|
Future<T> |
submit(Callable<T> task) |
Future<T> |
submit(Runnable task,
T result) |
Future<T> |
take() |
String |
toString() |
poll, poll
public CountingExecutorCompletionService(Executor executor)
public CountingExecutorCompletionService(Executor executor, BlockingQueue<Future<T>> completionQueue)
public Future<T> submit(Callable<T> task)
submit
in interface CompletionService<T>
submit
in class ExecutorCompletionService<T>
public Future<T> submit(Runnable task, T result)
submit
in interface CompletionService<T>
submit
in class ExecutorCompletionService<T>
public Future<T> take() throws InterruptedException
take
in interface CompletionService<T>
take
in class ExecutorCompletionService<T>
InterruptedException
Copyright © 2016 JBoss by Red Hat. All Rights Reserved.