Searched refs:futureQueue (Results 1 – 1 of 1) sorted by relevance
679 BlockingQueue<Future<T>> futureQueue = Queues.newLinkedBlockingQueue(); in invokeAnyImpl() local694 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()