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 <boost/lockfree/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>
Classes | |
class | concurrent::MpscQueue< T > |
Namespaces | |
namespace | concurrent |
Locking stuff. | |