A Queue with simple FIFO behavior.
Definition at line 22 of file FIFOQueue.h.
Public Member Functions | |
void | add (JobTask job_task) override |
See Queue::add. | |
bool | pop (JobTask &job_task) override |
See Queue::pop. | |
Public Member Functions inherited from RooFit::MultiProcess::Queue | |
virtual | ~Queue ()=default |
void | loop () |
The queue process's event loop. | |
void | process_master_message (M2Q message) |
Helper function for 'Queue::loop()'. | |
void | process_worker_message (std::size_t this_worker_id, W2Q message) |
Helper function for 'Queue::loop()'. | |
Private Attributes | |
std::queue< JobTask > | queue_ |
Additional Inherited Members | |
Protected Attributes inherited from RooFit::MultiProcess::Queue | |
std::size_t | N_tasks_ = 0 |
std::size_t | N_tasks_at_workers_ = 0 |
|
overridevirtual |
See Queue::add.
Implements RooFit::MultiProcess::Queue.
Definition at line 38 of file FIFOQueue.cxx.
See Queue::pop.
Implements RooFit::MultiProcess::Queue.
Definition at line 26 of file FIFOQueue.cxx.
|
private |
Definition at line 28 of file FIFOQueue.h.