/guava/android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
f = futureQueue.take( ) ;Future<T> f = futureQueue.poll( ) ;
Future<T> f = futureQueue.poll ( ) ;
long lastTime = timed ? System.nanoTime() : 0; Iterator<? extends Callable<T>> it = tasks.iterator(); futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); --ntasks; int active = 1; while (true) { <extra_id_0> if (f == null) { if (ntasks > 0) { --ntasks; futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); ++active; } else if (active == 0) {