Skip to main content

StageMailbox Struct

Single thread-safe inbox the runtime delivers messages into for one stage. More...

Declaration​

struct simaai::neat::graph::runtime::StageMailbox { ... }

Included Headers​

#include <StageMailbox.h>

Public Constructors Index​

StageMailbox (std::size_t capacity=0)

Construct a mailbox with the given inbox capacity (0 = unbounded). More...

Public Member Attributes Index​

BlockingQueue< StageMsg >inbox

Bounded blocking queue holding pending StageMsgs. More...

Description​

Single thread-safe inbox the runtime delivers messages into for one stage.

Wraps a BlockingQueue<StageMsg> sized at construction. The runtime pushes incoming messages into the mailbox; the stage's worker thread pops and dispatches them.

See Also

BlockingQueue

Definition at line 24 of file StageMailbox.h.

Public Constructors​

StageMailbox()​

simaai::neat::graph::runtime::StageMailbox::StageMailbox (std::size_t capacity=0)
 inline explicit

Construct a mailbox with the given inbox capacity (0 = unbounded).

Definition at line 26 of file StageMailbox.h.

26 explicit StageMailbox(std::size_t capacity = 0) : inbox(capacity) {}

Public Member Attributes​

inbox​

BlockingQueue<StageMsg> simaai::neat::graph::runtime::StageMailbox::inbox

Bounded blocking queue holding pending StageMsgs.

Definition at line 27 of file StageMailbox.h.

27 BlockingQueue<StageMsg> inbox;

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

Generated via doxygen2docusaurus 2.0.0 by Doxygen 1.9.8.