/guava/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
if ( nextToRun == null) { nextLabel = labelQueue.poll( ) ;nextToRun = waitQueue.poll( ) ;
nextToRun = waitQueue.poll ( ) ; nextLabel = labelQueue.poll ( ) ; if ( nextToRun == null ) {
try { while (true) { ListenerCallQueue.Event<L> nextToRun; Object nextLabel; synchronized (PerListenerQueue.this) { Preconditions.checkState(isThreadScheduled); <extra_id_0> isThreadScheduled = false; stillRunning = false; break; } } try {