#include <container.h>
Public Member Functions | |
MutexedQueue ()=default | |
bool | empty () const |
void | push_back (const T &t) |
void | push_back (T &&t) |
T | pop_frontNoEx (u32 wait_time_max_ms) |
T | pop_front (u32 wait_time_max_ms) |
T | pop_frontNoEx () |
T | pop_back (u32 wait_time_max_ms=0) |
T | pop_backNoEx (u32 wait_time_max_ms) |
T | pop_backNoEx () |
Protected Member Functions | |
std::mutex & | getMutex () |
std::deque< T > & | getQueue () |
Protected Attributes | |
std::deque< T > | m_queue |
std::mutex | m_mutex |
Semaphore | m_signal |
Friends | |
template<typename Key , typename U , typename Caller , typename CallerData > | |
class | RequestQueue |
|
default |
|
inline |
References MutexedQueue< T >::m_mutex, and MutexedQueue< T >::m_queue.
Referenced by Server::AsyncRunStep(), RequestQueue< Key, T, Caller, CallerData >::empty(), and MeshUpdateManager::getNextResult().
|
inlineprotected |
References MutexedQueue< T >::m_mutex.
Referenced by RequestQueue< Key, T, Caller, CallerData >::add().
|
inlineprotected |
References MutexedQueue< T >::m_queue.
Referenced by RequestQueue< Key, T, Caller, CallerData >::add().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::wait().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::wait().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::wait().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::wait().
Referenced by TextureSource::getTextureId(), RequestQueue< Key, T, Caller, CallerData >::pop(), and con::Connection::waitEvent().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::wait().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::wait().
Referenced by sound::ProxySoundManager::~ProxySoundManager(), Server::AsyncRunStep(), MeshUpdateManager::getNextResult(), ShaderSource::getShader(), RequestQueue< Key, T, Caller, CallerData >::pop(), con::ConnectionSendThread::run(), sound::OpenALSoundManager::run(), and sound::ProxySoundManager::step().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::post().
Referenced by RequestQueue< Key, T, Caller, CallerData >::add(), Server::AsyncRunStep(), Server::DeleteClient(), Server::handleAdminChat(), TermLogOutput::log(), TermLogOutput::logRaw(), Server::notifyPlayer(), Server::printToConsoleOnly(), RequestQueue< Key, T, Caller, CallerData >::pushResult(), con::Connection::putCommand(), con::Connection::putEvent(), MeshUpdateManager::putResult(), sound::OpenALSoundManager::send(), and sound::ProxySoundManager::send().
|
inline |
References MutexedQueue< T >::m_mutex, MutexedQueue< T >::m_queue, MutexedQueue< T >::m_signal, and Semaphore::post().
|
friend |
|
mutableprotected |
Referenced by MutexedQueue< T >::empty(), MutexedQueue< T >::getMutex(), MutexedQueue< T >::pop_back(), MutexedQueue< T >::pop_backNoEx(), MutexedQueue< T >::pop_backNoEx(), MutexedQueue< T >::pop_front(), MutexedQueue< T >::pop_frontNoEx(), MutexedQueue< T >::pop_frontNoEx(), MutexedQueue< T >::push_back(), and MutexedQueue< T >::push_back().
|
protected |
Referenced by MutexedQueue< T >::empty(), MutexedQueue< T >::getQueue(), MutexedQueue< T >::pop_back(), MutexedQueue< T >::pop_backNoEx(), MutexedQueue< T >::pop_backNoEx(), MutexedQueue< T >::pop_front(), MutexedQueue< T >::pop_frontNoEx(), MutexedQueue< T >::pop_frontNoEx(), MutexedQueue< T >::push_back(), and MutexedQueue< T >::push_back().
|
protected |