Home
last modified time | relevance | path

Searched refs:futureQueue (Results 1 – 1 of 1) sorted by relevance

/external/guava/guava/src/com/google/common/util/concurrent/
DMoreExecutors.java679 BlockingQueue<Future<T>> futureQueue = Queues.newLinkedBlockingQueue(); in invokeAnyImpl() local
694 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); in invokeAnyImpl()
699 Future<T> f = futureQueue.poll(); in invokeAnyImpl()
703 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); in invokeAnyImpl()
708 f = futureQueue.poll(nanos, TimeUnit.NANOSECONDS); in invokeAnyImpl()
716 f = futureQueue.take(); in invokeAnyImpl()