marlinmt::concurrency::ProcessorSequenceWorker Class Reference

ProcessorSequenceWorker class. More...

Inherits marlinmt::concurrency::WorkerBase< PEPScheduler::InputType, PEPScheduler::OutputType >.

Public Types
using	Base = WorkerBase< PEPScheduler::InputType, PEPScheduler::OutputType >
using	Input = Base::Input
using	Output = Base::Output
Public Types inherited from marlinmt::concurrency::WorkerBase< PEPScheduler::InputType, PEPScheduler::OutputType >
using	Input = PEPScheduler::InputType
using	Output = PEPScheduler::OutputType

Public Member Functions
	~ProcessorSequenceWorker ()=default
	ProcessorSequenceWorker (std::shared_ptr< Sequence > sequence)
	Constructor. More...
Public Member Functions inherited from marlinmt::concurrency::WorkerBase< PEPScheduler::InputType, PEPScheduler::OutputType >
virtual	~WorkerBase ()=default
virtual PEPScheduler::OutputType	process (PEPScheduler::InputType &&data)=0
	Process a single queued data taken form the thread pool. More...

Private Member Functions
Output	process (Input &&event) override

Private Attributes
std::shared_ptr< Sequence >	_sequence {nullptr}
	< The processor sequence to run in the worker thread More...

Additional Inherited Members
Protected Member Functions inherited from marlinmt::concurrency::WorkerBase< PEPScheduler::InputType, PEPScheduler::OutputType >
void	processElement (QueueElement< PEPScheduler::InputType, PEPScheduler::OutputType > &element)
	Process queued element from the thread pool. More...

Detailed Description

ProcessorSequenceWorker class.

Definition at line 25 of file PEPScheduler.cc.

Member Typedef Documentation

Base

using marlinmt::concurrency::ProcessorSequenceWorker::Base = WorkerBase<PEPScheduler::InputType,PEPScheduler::OutputType>

Definition at line 27 of file PEPScheduler.cc.

Input

using marlinmt::concurrency::ProcessorSequenceWorker::Input = Base::Input

Definition at line 28 of file PEPScheduler.cc.

Output

using marlinmt::concurrency::ProcessorSequenceWorker::Output = Base::Output

Definition at line 29 of file PEPScheduler.cc.

Constructor & Destructor Documentation

~ProcessorSequenceWorker()

marlinmt::concurrency::ProcessorSequenceWorker::~ProcessorSequenceWorker ( )

default

ProcessorSequenceWorker()

marlinmt::concurrency::ProcessorSequenceWorker::ProcessorSequenceWorker

(

std::shared_ptr< Sequence >

sequence

)

Constructor.

Parameters

sequence

the processor sequence to execute

Definition at line 54 of file PEPScheduler.cc.

Member Function Documentation

process()

ProcessorSequenceWorker::Output marlinmt::concurrency::ProcessorSequenceWorker::process ( Input &&  event )

overrideprivate

Definition at line 61 of file PEPScheduler.cc.

References _sequence.

Member Data Documentation

_sequence

std::shared_ptr<Sequence> marlinmt::concurrency::ProcessorSequenceWorker::_sequence {nullptr}

private

< The processor sequence to run in the worker thread

Definition at line 48 of file PEPScheduler.cc.

Referenced by process().

---

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

• PEPScheduler.cc