Hedgehog
3.1.0
A library to generate hybrid pipeline workflow systems
|
Concrete implementation of the receiver core abstraction for multiple types using a std::queue. More...
#include "multi_queue_receivers.h"
Public Member Functions | |
MultiQueueReceivers () | |
Constructor using an abstraction for callbacks. | |
virtual | ~MultiQueueReceivers ()=default |
Default destructor. | |
![]() | |
QueueReceiver () | |
Default constructor. | |
virtual | ~QueueReceiver ()=default |
Default destructor. | |
void | receive (std::shared_ptr< Inputs > const data) final |
Receive a data and store it in the queue. | |
std::shared_ptr< Inputs > | getInputData () override |
Get a data from the queue. | |
size_t | numberElementsReceived () const override |
Accessor to the current size of the queue. | |
size_t | maxNumberElementsReceived () const override |
Accessor to the maximum queue size. | |
bool | empty () const override |
Test if the queue is empty. | |
std::set< abstraction::SenderAbstraction< Inputs > * > const & | connectedSenders () const override |
Accessor to the set of connected senders. | |
void | addSender (abstraction::SenderAbstraction< Inputs > *const sender) override |
Add a sender to the set of connected senders. | |
void | removeSender (abstraction::SenderAbstraction< Inputs > *const sender) override |
Remove a sender to the set of connected senders. | |
![]() | |
ImplementorReceiver () | |
Default constructor. | |
virtual | ~ImplementorReceiver ()=default |
Default destructor. | |
std::set< abstraction::ReceiverAbstraction< Input > * > & | receivers () |
Accessor to the linked ReceiverAbstraction. | |
virtual void | initialize (abstraction::ReceiverAbstraction< Input > *receiverAbstraction) |
Initialize the implementor Receiver by setting the corresponding abstraction. | |
virtual std::set< abstraction::SenderAbstraction< Input > * > const & | connectedSenders () const =0 |
Accessor to the connected senders. | |
virtual void | addSender (abstraction::SenderAbstraction< Input > *sender)=0 |
Add a SenderAbstraction. | |
virtual void | removeSender (abstraction::SenderAbstraction< Input > *sender)=0 |
Remove a SenderAbstraction. | |
virtual void | receive (std::shared_ptr< Input > data)=0 |
Receive data interface. | |
virtual std::shared_ptr< Input > | getInputData ()=0 |
Accessor to a received data. | |
virtual size_t | numberElementsReceived () const =0 |
Accessor to number of data waiting to be processed in the queue. | |
virtual size_t | maxNumberElementsReceived () const =0 |
Accessor to the maximum number of data waiting to be processed in the queue during the whole execution. | |
virtual bool | empty () const =0 |
Test if the receiver is empty or not. | |
Additional Inherited Members | |
![]() | |
std::unique_ptr< std::set< abstraction::ReceiverAbstraction< Input > * > > | abstractReceivers_ = nullptr |
Set of linked ReceiverAbstraction. | |
Concrete implementation of the receiver core abstraction for multiple types using a std::queue.
Inputs | List of input types |
Definition at line 18 of file multi_queue_receivers.h.
|
inlineexplicit |
Constructor using an abstraction for callbacks.
Definition at line 21 of file multi_queue_receivers.h.
|
virtualdefault |
Default destructor.