RooFit::MultiProcess::FIFOQueue Class Reference

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.
void	loop ()
	The queue process's event loop.
bool	pop (JobTask &job_task) override
	See Queue::pop.
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()'.

Protected Attributes
std::size_t	N_tasks_ = 0
std::size_t	N_tasks_at_workers_ = 0

Private Attributes
std::queue< JobTask >	queue_

#include </home/stephan/code/root-2/roofit/multiprocess/src/FIFOQueue.h>

Inheritance diagram for RooFit::MultiProcess::FIFOQueue:

Member Function Documentation

add()

void RooFit::MultiProcess::FIFOQueue::add ( JobTask job_task )

overridevirtual

See Queue::add.

Implements RooFit::MultiProcess::Queue.

Definition at line 38 of file FIFOQueue.cxx.

loop()

void RooFit::MultiProcess::Queue::loop ( )

inherited

The queue process's event loop.

Polls for incoming messages from other processes and handles them.

Definition at line 83 of file Queue.cxx.

pop()

bool RooFit::MultiProcess::FIFOQueue::pop ( JobTask & job_task )

overridevirtual

See Queue::pop.

Implements RooFit::MultiProcess::Queue.

Definition at line 26 of file FIFOQueue.cxx.

process_master_message()

void RooFit::MultiProcess::Queue::process_master_message ( M2Q message )

inherited

Helper function for 'Queue::loop()'.

Definition at line 43 of file Queue.cxx.

process_worker_message()

void RooFit::MultiProcess::Queue::process_worker_message ( std::size_t this_worker_id, W2Q message )

inherited

Helper function for 'Queue::loop()'.

Definition at line 60 of file Queue.cxx.

Member Data Documentation

N_tasks_

std::size_t RooFit::MultiProcess::Queue::N_tasks_ = 0

protectedinherited

Definition at line 43 of file Queue.h.

N_tasks_at_workers_

std::size_t RooFit::MultiProcess::Queue::N_tasks_at_workers_ = 0

protectedinherited

Definition at line 44 of file Queue.h.

queue_

std::queue<JobTask> RooFit::MultiProcess::FIFOQueue::queue_

private

Definition at line 28 of file FIFOQueue.h.

---

The documentation for this class was generated from the following files:

• roofit/multiprocess/src/FIFOQueue.h
• roofit/multiprocess/src/FIFOQueue.cxx