Public Member Functions | |
EventDispatcher (T listener, int queueCapacity) | |
void | loop () throws InterruptedException |
void | signal (final SignalRunnable< T > signalRunnable) |
Private Attributes | |
final CircularBlockingDeque < SignalRunnable< T > > | events |
final T | listener |
<T> | the listener type |
Definition at line 26 of file EventDispatcher.java.
org.ros.concurrent.EventDispatcher< T >.EventDispatcher | ( | T | listener, |
int | queueCapacity | ||
) | [inline] |
Definition at line 31 of file EventDispatcher.java.
void org.ros.concurrent.EventDispatcher< T >.loop | ( | ) | throws InterruptedException [inline, virtual] |
The body of the loop. This will run continuously until the CancellableLoop has been interrupted externally or by calling cancel().
Implements org.ros.concurrent.CancellableLoop.
Definition at line 41 of file EventDispatcher.java.
void org.ros.concurrent.EventDispatcher< T >.signal | ( | final SignalRunnable< T > | signalRunnable | ) | [inline] |
Definition at line 36 of file EventDispatcher.java.
final CircularBlockingDeque<SignalRunnable<T> > org.ros.concurrent.EventDispatcher< T >.events [private] |
Definition at line 29 of file EventDispatcher.java.
final T org.ros.concurrent.EventDispatcher< T >.listener [private] |
Definition at line 28 of file EventDispatcher.java.