Package org.ros.concurrent

package org.ros.concurrent

Provides utility classes for common concurrent programming operations.

Related Packages

Package	Description
org.ros

Class	Description
CancellableLoop	An interruptable loop that can be run by an ExecutorService.
CircularBlockingDeque<T>	A deque that removes head or tail elements when the number of elements exceeds the limit and blocks on CircularBlockingDeque.takeFirst() and CircularBlockingDeque.takeLast() when there are no elements available.
DefaultScheduledExecutorService	This wraps a Executors.newCachedThreadPool() and a Executors.newScheduledThreadPool(int) to provide the functionality of both in a single ScheduledExecutorService.
DroppedEntryException
EventDispatcher<T>
Holder<T>	A mutable object that may contain a value to another object.
ListenerGroup<T>	A group of listeners.
Rate
RetryingExecutorService	Wraps an ScheduledExecutorService to execute Callables with retries.
SharedScheduledExecutorService	A ScheduledExecutorService which cannot be shut down.
SignalRunnable<T>	Decouples specific listener interfaces from the signaling implementation.
WallTimeRate
WatchdogTimer	A WatchdogTimer expects to receive a WatchdogTimer.pulse() at least once every WatchdogTimer.period WatchdogTimer.units.