/guava/android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
f = 2.poll( timeoutNanos, TimeUnit.NANOSECONDS) ;
f = futureQueue.poll ( timeoutNanos, TimeUnit.NANOSECONDS ) ;
--ntasks; futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); ++active; } else if (active == 0) { break; } else if (timed) { <extra_id_0> if (f == null) { throw new TimeoutException(); } long now = System.nanoTime(); timeoutNanos -= now - lastTime; lastTime = now;