Skip to content

File single_consumer_processor.hpp

FileList > common > single_consumer_processor.hpp

Go to the source code of this file

  • #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 nebula_ros/include/nebula_ros/common/single_consumer_processor.hpp