#include <queue.hpp>
template<typename T>
class osmium::thread::Queue< T >
A thread-safe queue.
◆ Queue() [1/3]
Construct a multithreaded queue.
- Parameters
-
max_size | Maximum number of elements in the queue. Set to 0 for an unlimited size. |
name | Optional name for this queue. (Used for debugging.) |
◆ Queue() [2/3]
◆ Queue() [3/3]
◆ ~Queue()
◆ empty()
◆ operator=() [1/2]
◆ operator=() [2/2]
◆ push()
Push an element onto the queue. If the queue has a max size, this call will block if the queue is full.
◆ size()
◆ try_pop()
◆ wait_and_pop()
◆ m_data_available
Used to signal consumers when data is available in the queue.
◆ m_max_size
Maximum size of this queue. If the queue is full pushing to the queue will block.
◆ m_mutex
◆ m_name
Name of this queue (for debugging only).
◆ m_queue
◆ m_space_available
Used to signal producers when queue is not full.
The documentation for this class was generated from the following file: