AceSmartSoft API Documentation
|
unbounded message queue for communication between threads. More...
#include <smartMessageQueue.hh>
Public Member Functions | |
MessageQueue () | |
constructor. More... | |
virtual | ~MessageQueue () |
destructor More... | |
void | enqueue (const Item &item) |
enqueue an item. More... | |
Item | dequeue () |
dequeue an item. More... | |
unbounded message queue for communication between threads.
This queue can be used to connect two threads together, for example to enqueue commands and queries that can't be executed inside a SendHandler, or QueryHandler.
Queue items are processed in FIFO order.
SmartACE::MessageQueue< Item >::MessageQueue | ( | ) |
constructor.
|
virtual |
destructor
Item SmartACE::MessageQueue< Item >::dequeue | ( | ) |
dequeue an item.
dequeues the head item. if no item is available, blocks till one arrives.
void SmartACE::MessageQueue< Item >::enqueue | ( | const Item & | item | ) |
enqueue an item.
item | to enqueue. A copy of the item is stored in the queue |