private static final class Dispatcher.PerThreadQueuedDispatcher extends Dispatcher
Dispatcher.perThreadDispatchQueue()
dispatcher.Modifier and Type | Class and Description |
---|---|
private static class |
Dispatcher.PerThreadQueuedDispatcher.Event |
Modifier and Type | Field and Description |
---|---|
private java.lang.ThreadLocal<java.lang.Boolean> |
dispatching
Per-thread dispatch state, used to avoid reentrant event dispatching.
|
private java.lang.ThreadLocal<java.util.Queue<Dispatcher.PerThreadQueuedDispatcher.Event>> |
queue
Per-thread queue of events to dispatch.
|
Modifier | Constructor and Description |
---|---|
private |
PerThreadQueuedDispatcher() |
Modifier and Type | Method and Description |
---|---|
(package private) void |
dispatch(java.lang.Object event,
java.util.Iterator<Subscriber> subscribers)
Dispatches the given
event to the given subscribers . |
immediate, legacyAsync, perThreadDispatchQueue
private final java.lang.ThreadLocal<java.util.Queue<Dispatcher.PerThreadQueuedDispatcher.Event>> queue
private final java.lang.ThreadLocal<java.lang.Boolean> dispatching
void dispatch(java.lang.Object event, java.util.Iterator<Subscriber> subscribers)
Dispatcher
event
to the given subscribers
.dispatch
in class Dispatcher