sbit::mpscq::Processor< Payload > Class Template Reference

#include <mpscq.h>

Inheritance diagram for sbit::mpscq::Processor< Payload >:

Collaboration diagram for sbit::mpscq::Processor< Payload >:

Public Member Functions
	Processor (Queue &queue)
Public Member Functions inherited from sbit::mpscq::ProcessorBase
	ProcessorBase (Queue &queue)
virtual void	afterBatch ()
virtual void	onIdle ()
void	startProcessing ()
void	interrupt ()
	ProcessorBase (const ProcessorBase &other)=delete
ProcessorBase &	operator= (const ProcessorBase &other)=delete
	ProcessorBase (ProcessorBase &&other)=delete
ProcessorBase &	operator= (ProcessorBase &&other)=delete

Protected Member Functions
virtual void	process (const Payload &payload)=0

Detailed Description

template<typename Payload>
class sbit::mpscq::Processor< Payload >

Strongly-typed consumer

Wraps the cast from the Queue::Envelope type to the Payload type

Template Parameters

Payload

Is the type of the useful payload processed via the queue

Constructor & Destructor Documentation

Processor()

template<typename Payload >

sbit::mpscq::Processor< Payload >::Processor ( Queue &  queue )

inlineexplicit

Constructs a processor

Parameters

queue

Is the queue from which elements are consumed

Member Function Documentation

process()

template<typename Payload >

virtual void sbit::mpscq::Processor< Payload >::process ( const Payload &  payload )

protectedpure virtual

Process a message

Parameters

payload

Is the message contents to be processed

Returns

nothing

---

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

• /home/florin/work/mpscq/include/sbit/mpscq.h