/guava/guava/src/com/google/common/eventbus/Dispatcher.java
return Queues.newArrayDeque ( ) ;
abstract void dispatch(Object event, Iterator<Subscriber> subscribers); private static final class PerThreadQueuedDispatcher extends Dispatcher { private final ThreadLocal<Queue<Event>> queue = new ThreadLocal<Queue<Event>>() { @Override protected Queue<Event> initialValue() { <extra_id_0> } }; private final ThreadLocal<Boolean> dispatching = new ThreadLocal<Boolean>() { @Override protected Boolean initialValue() {