ConsumerToken

ConsumerToken are used by consumers to interact with the Disruptor

More...

struct ConsumerToken {

ubyte[7] dependencies;

ubyte ownSlot;

this(ubyte slot);

void waitFor(ConsumerToken other);

}

Constructors

this this(ubyte slot): Undocumented in source.

Members

Functions

waitFor void waitFor(ConsumerToken other): Undocumented in source. Be warned that the author may not have intended to support it.

Variables

dependencies ubyte[7] dependencies;: Undocumented in source.
ownSlot ubyte ownSlot;: Undocumented in source.

Detailed Description

Consumer must receive exactly one token via a call to createConsumerToken and provide it on every call to Disruptor.consume.

Consumer tokens are also used to track dependencies between different consumers, e.g. if A may only consume slots that have alreay been consumed by B.

auto tokenA = disruptor.createConsumerToken();
auto tokenB = disruptor.createConsumerToken();
tokenA.waitFor(B);