Searched refs:completionQueue (Results 1 – 1 of 1) sorted by relevance
80 private final BlockingQueue<Future<V>> completionQueue; field in ExecutorCompletionService87 BlockingQueue<Future<V>> completionQueue) { in QueueingFuture() argument90 this.completionQueue = completionQueue; in QueueingFuture()93 private final BlockingQueue<Future<V>> completionQueue; field in ExecutorCompletionService.QueueingFuture94 protected void done() { completionQueue.add(task); } in done()125 this.completionQueue = new LinkedBlockingQueue<Future<V>>(); in ExecutorCompletionService()142 BlockingQueue<Future<V>> completionQueue) { in ExecutorCompletionService() argument143 if (executor == null || completionQueue == null) in ExecutorCompletionService()148 this.completionQueue = completionQueue; in ExecutorCompletionService()154 executor.execute(new QueueingFuture<V>(f, completionQueue)); in submit()[all …]