java.lang.Object java.util.concurrent.ExecutorCompletionService<V>
Executor
public ExecutorCompletionService(Executor executor)
LinkedBlockingQueue
public ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue)
public Future<V> poll()
public Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException
public Future<V> submit(Runnable task, V result)
public Future<V> submit(Callable<V> task)
public Future<V> take() throws InterruptedException