queue_mpmc_mutex
A fixed capacity multi-producer, multi-consumer queue for multi-threaded systems that uses etl::mutex to control
access.
etl::queue_mpmc_mutex<typename T, const size_t SIZE>
Inherits from etl::iqueue_mpmc_mutex<T>
etl::iqueue_mpmc_mutex may be used as a size independent pointer or reference type for any etl::queue_mpmc_mutex
instance of the same implementation.
Member types
value_type T
size_type std::size_t
pointer value_type*
const_pointer const value_type*
reference value_type&
const_reference const value_type&
Constructor
queue_mpmc_mutex();
Capacity
bool empty() const
Returns true if the size of the queue is zero, otherwise false.
bool full() const
Returns true if the size of the queue is SIZE, otherwise false.
size_t size() const
Returns the size of the queue.
size_t available() const
size_t available_from_isr() const
Returns the remaining available capacity in the queue.
ETL_CONSTEXPR size_t max_size() const
Returns the maximum possible size of the queue.
ETL_CONSTEXPR size_t capacity() const
Returns the maximum possible size of the queue.
Modifiers
bool push(parameter_t value);
Pushes a value to the back of the queue.
Returns true if successful, otherwise false.
bool pop();
Pop a value from the front of the list.
Returns true if successful, otherwise false.
bool pop(T& value);
Pop a value from the front of the list and place it in value.
Returns true if successful, otherwise false.
void clear();
Clears the queue to a size of zero.
Notes
Remember that thread context switcches may occur between calls to the access protected functions. For example, a call
to empty() may return true, but a subsequent call to pop() may succeed if a context switch occurred between the two
and pushed a new value.
Example
etl::queue_mpmc_mutex<char, 10> queue;
int main()
{
while (true)
{
char c;
if (queue.pop(c))
{
Print(c);
}
}
}
void FunctionInThread1(char c)
{
while (!queue.push(c))
{
}
}
void FunctionInThread2(char c)
{
while (!queue.push(c))
{
}
}