Modifier and Type | Method and Description |
---|---|
protected EventQueue<T> |
Controller.createEventQueue(Object key)
Creates a new
EventQueue when invoked. |
protected EventQueue<T> |
EventQueueCollection.createEventQueue(Object key)
|
@Blocking EventQueue<T> |
EventQueueCollection.get()
Implements the
Supplier.get() contract by
removing and returning an EventQueue if
one is available, blocking if one is not and
returning null only if the current thread is interrupted or this EventQueueCollection is
closing. |
Modifier and Type | Method and Description |
---|---|
void |
ResourceTrackingEventQueueConsumer.accept(EventQueue<? extends T> eventQueue)
Loops through all the
AbstractEvent s in the supplied EventQueue , keeping track
of the HasMetadata it concerns along the way by
synchronizing on and writing to the Map
supplied at
construction time. |
Modifier and Type | Method and Description |
---|---|
@NonBlocking Future<?> |
EventQueueCollection.start(Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Starts a new
Thread that, until EventQueueCollection.close() is
called, removes EventQueue s from this EventQueueCollection and supplies them to the supplied Consumer , and returns a Future representing this task. |
Constructor and Description |
---|
Controller(X operation,
Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Creates a new
Controller but does not start it. |
Controller(X operation,
Duration synchronizationInterval,
Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Creates a new
Controller but does not start it. |
Controller(X operation,
Duration synchronizationInterval,
Map<Object,T> knownObjects,
Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Creates a new
Controller but does not start it. |
Controller(X operation,
Map<Object,T> knownObjects,
Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Creates a new
Controller but does not start it. |
Controller(X operation,
ScheduledExecutorService synchronizationExecutorService,
Duration synchronizationInterval,
Function<? super Throwable,Boolean> errorHandler,
Map<Object,T> knownObjects,
Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Creates a new
Controller but does not start it. |
Controller(X operation,
ScheduledExecutorService synchronizationExecutorService,
Duration synchronizationInterval,
Map<Object,T> knownObjects,
Consumer<? super EventQueue<? extends T>> eventQueueConsumer)
Creates a new
Controller but does not start it. |
Copyright © 2017–2021, microBean™. All rights reserved.