The dispatcher maintains a daemon thread that repeatedly removes queued {@code EventObject}
* instances, looks up listeners that registered interest in the originating event source and the
* supplied method name, and invokes that method with the event as its sole argument. Listener look-
- * * ups and queue mutations are synchronized on the dispatcher instance, allowing multiple producer
+ * * ups and queue mutations are synchronized in the dispatcher instance, allowing multiple producer
* threads to submit events while the consumer thread drains the queue. Method lookups are cached to
- * avoid repeated reflective discovery, but execution order remains FIFO for submitted events. When
- * no listeners are registered for a given method name and source, the event is silently skipped.
+ * avoid repeated reflective discovery, but the execution order remains FIFO for submitted events.
+ * When no listeners are registered for a given method name and source, the event is silently
+ * skipped.
*
*
Use this class when you need a lightweight, per-source event bus without committing to a
* broader framework. Typical usage registers listeners tied to a particular publisher object and
@@ -46,11 +47,11 @@ public class ReflectiveEventDispatch implements Runnable {
private static final Logger LOGGER = Logger.getLogger(ReflectiveEventDispatch.class.getName());
- private final Thread thread;
private final Map methodCache = new HashMap<>();
private final Map>> listeners = new HashMap<>();
// Holds either Tuple(event, methodName) or a sentinel (this) to signal shutdown
private final ArrayDeque