A synchronized queue.
More...
#include <XrdClJobManager.hh>
XrdCl::JobManager::JobManager |
( |
uint32_t |
workers | ) |
|
|
inline |
XrdCl::JobManager::~JobManager |
( |
| ) |
|
|
inline |
bool XrdCl::JobManager::Finalize |
( |
| ) |
|
Finalize the job manager, clear the queues.
bool XrdCl::JobManager::Initialize |
( |
| ) |
|
Initialize the job manager.
bool XrdCl::JobManager::IsWorker |
( |
| ) |
|
|
inline |
void XrdCl::JobManager::QueueJob |
( |
Job * |
job, |
|
|
void * |
arg = 0 |
|
) |
| |
|
inline |
Add a job to be run.
References pJobs.
void XrdCl::JobManager::RunJobs |
( |
| ) |
|
bool XrdCl::JobManager::Start |
( |
| ) |
|
bool XrdCl::JobManager::Stop |
( |
| ) |
|
void XrdCl::JobManager::StopWorkers |
( |
uint32_t |
n | ) |
|
|
private |
Stop all workers up to n'th.
bool XrdCl::JobManager::pRunning |
|
private |
std::vector<pthread_t> XrdCl::JobManager::pWorkers |
|
private |
The documentation for this class was generated from the following file: