Multiple producer, single consumer queue.
Definition in file mpsc_queue.hpp.
Go to the source code of this file.
#include <atomic>#include <limits>#include <memory>#include <userver/concurrent/impl/intrusive_mpsc_queue.hpp>#include <userver/concurrent/impl/semaphore_capacity_control.hpp>#include <userver/concurrent/queue_helpers.hpp>#include <userver/engine/deadline.hpp>#include <userver/engine/semaphore.hpp>#include <userver/engine/single_consumer_event.hpp>#include <userver/engine/task/cancel.hpp>#include <userver/utils/assert.hpp>
This graph shows which files directly or indirectly include this file:Classes | |
| class | concurrent::MpscQueue< T > |
Namespaces | |
| namespace | concurrent |
| Locking stuff. | |