Package org.ros.concurrent

Class EventDispatcher<T>

java.lang.Object

org.ros.concurrent.CancellableLoop

org.ros.concurrent.EventDispatcher<T>

Type Parameters:

T - the listener type

All Implemented Interfaces:

Runnable

public class EventDispatcher<T>
extends CancellableLoop

Author:

damonkohler@google.com (Damon Kohler)

Constructor Summary

Constructors

Constructor	Description
EventDispatcher(T listener, int queueCapacity)

Method Summary

Modifier and Type	Method	Description
T	getListener()
void	loop()	The body of the loop.
void	signal(SignalRunnable<T> signalRunnable)

Methods inherited from class org.ros.concurrent.CancellableLoop

cancel, handleInterruptedException, isRunning, run, setup

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

EventDispatcher

public EventDispatcher(T listener,
 int queueCapacity)

Method Details

signal

public void signal(SignalRunnable<T> signalRunnable)

loop

public void loop()
          throws InterruptedException

Description copied from class: CancellableLoop

The body of the loop. This will run continuously until the CancellableLoop has been interrupted externally or by calling CancellableLoop.cancel().

Specified by:

loop in class CancellableLoop

Throws:

InterruptedException

getListener

public T getListener()