/guava/guava/src/com/google/common/eventbus/Dispatcher.java
checkNotNull ( subscribers ) ;
return false; } }; @Override void dispatch(Object event, Iterator<Subscriber> subscribers) { checkNotNull(event); <extra_id_0> Queue<Event> queueForThread = requireNonNull(queue.get()); queueForThread.offer(new Event(event, subscribers)); if (!dispatching.get()) { dispatching.set(true); try { Event nextEvent;