Package org.ros.concurrent
package org.ros.concurrent
Provides utility classes for common concurrent programming operations.
-
ClassDescriptionAn interruptable loop that can be run by an
ExecutorService.A deque that removes head or tail elements when the number of elements exceeds the limit and blocks onCircularBlockingDeque.takeFirst()andCircularBlockingDeque.takeLast()when there are no elements available.This wraps aExecutors.newCachedThreadPool()and aExecutors.newScheduledThreadPool(int)to provide the functionality of both in a singleScheduledExecutorService.Holder<T>A mutable object that may contain a value to another object.A group of listeners.Wraps anScheduledExecutorServiceto executeCallables with retries.AScheduledExecutorServicewhich cannot be shut down.Decouples specific listener interfaces from the signaling implementation.AWatchdogTimerexpects to receive aWatchdogTimer.pulse()at least once everyWatchdogTimer.periodWatchdogTimer.units.