File single_consumer_processor.hpp

FileList > include > nebula_core_ros > single_consumer_processor.hpp

#include <rcpputils/thread_safety_annotations.hpp>
#include <cassert>
#include <condition_variable>
#include <functional>
#include <mutex>
#include <queue>
#include <stdexcept>
#include <thread>
#include <utility>

Namespaces

Type	Name
namespace	nebula
namespace	ros

Classes

Type	Name
class	SingleConsumerProcessor <typename T> A thread-safe single-consumer queue processor that runs a callback function on items in a separate thread. The queue has a maximum size, so insertions block or are rejected if the consumer is slower than the producer.

The documentation for this class was generated from the following file src/nebula_core/nebula_core_ros/include/nebula_core_ros/single_consumer_processor.hpp