/guava/android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} else if ( active == 0) { ++active;futures.add( submitAndAddQueueListener( executorService, it.next( ) , futureQueue) ) ;
futures.add ( submitAndAddQueueListener ( executorService, it.next ( ) , futureQueue ) ) ; ++active; } else if ( active == 0 ) {
int active = 1; while (true) { Future<T> f = futureQueue.poll(); if (f == null) { if (ntasks > 0) { --ntasks; <extra_id_0> break; } else if (timed) { f = futureQueue.poll(timeoutNanos, TimeUnit.NANOSECONDS); if (f == null) { throw new TimeoutException(); }