#include <container.h>
Public Member Functions | |
MutexedQueue ()=default | |
bool | empty () const |
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 Client::~Client(), Server::AsyncRunStep(), RequestQueue< Key, T, Caller, CallerData >::empty(), and Client::step().
|
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 CItemDefManager::getClientCached(), TextureSource::getTextureId(), and RequestQueue< Key, T, Caller, CallerData >::pop().
|
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 Client::~Client(), Server::AsyncRunStep(), ShaderSource::getShader(), RequestQueue< Key, T, Caller, CallerData >::pop(), and Client::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(), MeshUpdateThread::doUpdate(), Server::handleAdminChat(), TermLogOutput::log(), TermLogOutput::logRaw(), Server::notifyPlayer(), and Server::printToConsoleOnly().
|
friend |
|
mutableprotected |
|
protected |
|
protected |