#include <queue.hpp>
template<typename T>
class osmium::thread::Queue< T >
A thread-safe queue.
§ Queue()
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()
§ empty()
§ 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: