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