LibreOffice Module cppu (master) 1
|
#include <jobqueue.hxx>
Public Member Functions | |
JobQueue () | |
void | add (void *pThreadSpecificData, RequestFun *doRequest) |
void * | enter (void const *nDisposeId, bool bReturnWhenNoJob=false) |
void | dispose (void const *nDisposeId) |
void | suspend () |
void | resume () |
bool | isEmpty () const |
bool | isCallstackEmpty () const |
bool | isBusy () const |
Private Attributes | |
std::mutex | m_mutex |
std::deque< struct Job > | m_lstJob |
std::deque< void const * > | m_lstCallstack |
sal_Int32 | m_nToDo |
bool | m_bSuspended |
std::condition_variable | m_cndWait |
DisposedCallerAdminHolder | m_DisposedCallerAdmin |
Definition at line 44 of file jobqueue.hxx.
cppu_threadpool::JobQueue::JobQueue | ( | ) |
Definition at line 29 of file jobqueue.cxx.
void cppu_threadpool::JobQueue::add | ( | void * | pThreadSpecificData, |
RequestFun * | doRequest | ||
) |
Definition at line 36 of file jobqueue.cxx.
References m_bSuspended, m_cndWait, m_lstJob, m_mutex, and m_nToDo.
Referenced by cppu_threadpool::ThreadPool::addJob().
void cppu_threadpool::JobQueue::dispose | ( | void const * | nDisposeId | ) |
Definition at line 122 of file jobqueue.cxx.
References m_cndWait, m_lstCallstack, and m_mutex.
void * cppu_threadpool::JobQueue::enter | ( | void const * | nDisposeId, |
bool | bReturnWhenNoJob = false |
||
) |
Definition at line 48 of file jobqueue.cxx.
References cppu_threadpool::Job::doRequest, m_bSuspended, m_cndWait, m_DisposedCallerAdmin, m_lstCallstack, m_lstJob, m_mutex, m_nToDo, and cppu_threadpool::Job::pThreadSpecificData.
Referenced by cppu_threadpool::ThreadPool::enter(), and cppu_threadpool::ORequestThread::run().
bool cppu_threadpool::JobQueue::isBusy | ( | ) | const |
Definition at line 168 of file jobqueue.cxx.
bool cppu_threadpool::JobQueue::isCallstackEmpty | ( | ) | const |
Definition at line 162 of file jobqueue.cxx.
References m_lstCallstack, and m_mutex.
Referenced by cppu_threadpool::ThreadPool::enter().
bool cppu_threadpool::JobQueue::isEmpty | ( | ) | const |
Definition at line 156 of file jobqueue.cxx.
References m_lstJob, and m_mutex.
Referenced by cppu_threadpool::ORequestThread::run().
void cppu_threadpool::JobQueue::resume | ( | ) |
Definition at line 146 of file jobqueue.cxx.
References m_bSuspended, m_cndWait, m_lstJob, and m_mutex.
void cppu_threadpool::JobQueue::suspend | ( | ) |
Definition at line 140 of file jobqueue.cxx.
References m_bSuspended, and m_mutex.
Referenced by cppu_threadpool::ThreadPool::addJob().
|
private |
|
private |
|
private |
Definition at line 68 of file jobqueue.hxx.
Referenced by enter().
|
private |
Definition at line 64 of file jobqueue.hxx.
Referenced by dispose(), enter(), and isCallstackEmpty().
|
private |
|
mutableprivate |
Definition at line 62 of file jobqueue.hxx.
Referenced by add(), dispose(), enter(), isBusy(), isCallstackEmpty(), isEmpty(), resume(), and suspend().
|
private |
Definition at line 65 of file jobqueue.hxx.