libcppa
Version 0.1
|
#include <message_queue.hpp>
Public Member Functions | |
message_queue () | |
virtual void | enqueue (actor *sender, const any_tuple &msg)=0 |
virtual const any_tuple & | dequeue ()=0 |
virtual void | dequeue (invoke_rules &rules)=0 |
virtual void | dequeue (timed_invoke_rules &rules)=0 |
virtual bool | try_dequeue (any_tuple &)=0 |
virtual bool | try_dequeue (invoke_rules &)=0 |
bool | trap_exit () const |
void | trap_exit (bool value) |
any_tuple & | last_dequeued () |
actor_ptr & | last_sender () |
A message queue with many-writers-single-reader semantics.
cppa::message_queue::message_queue | ( | ) |
Creates an instance with trap_exit() == false
.
virtual const any_tuple& cppa::message_queue::dequeue | ( | ) | [pure virtual] |
Dequeues the oldest message (FIFO order) from the message queue.
virtual void cppa::message_queue::dequeue | ( | invoke_rules & | rules | ) | [pure virtual] |
Removes the first element from the queue that is matched by rules
and invokes the corresponding callback.
rules |
virtual void cppa::message_queue::dequeue | ( | timed_invoke_rules & | rules | ) | [pure virtual] |
rules |
Enqueues a new element to the message queue.
msg | The new message. |
any_tuple & cppa::message_queue::last_dequeued | ( | ) |
Gets the last dequeued message.
actor_ptr & cppa::message_queue::last_sender | ( | ) |
Gets the sender of the last dequeued message.
bool cppa::message_queue::trap_exit | ( | ) | const |
void cppa::message_queue::trap_exit | ( | bool | value | ) |
virtual bool cppa::message_queue::try_dequeue | ( | any_tuple & | ) | [pure virtual] |
virtual bool cppa::message_queue::try_dequeue | ( | invoke_rules & | ) | [pure virtual] |