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.
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

#include </github/home/ROOT-CI/src/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.

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.

Member Data Documentation

queue_

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

private

Definition at line 28 of file FIFOQueue.h.