Searched defs:completionQueue (Results 1 - 1 of 1) sorted by relevance

/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DExecutorCompletionService.java110 private final BlockingQueue<Future<V>> completionQueue; field in class:ExecutorCompletionService
120 protected void done() { completionQueue.add(task); }
152 this.completionQueue = new LinkedBlockingQueue<Future<V>>();
161 * @param completionQueue the queue to use as the completion queue
166 * @throws NullPointerException if executor or completionQueue are {@code null}
169 BlockingQueue<Future<V>> completionQueue) {
170 if (executor == null || completionQueue == null)
175 this.completionQueue = completionQueue;
193 return completionQueue
168 ExecutorCompletionService(Executor executor, BlockingQueue<Future<V>> completionQueue) argument
[all...]

Completed in 1778 milliseconds