Manager.Manager

A queue manager

template Manager(Item)

class Manager {

import core.sync.mutex : Mutex;;

this(size_t maxIter);

Result!(QueueType*, string) newQueue();

bool removeQueue(QueueType* queue);

bool removeQueue(QueueKey key);

Result!(bool, QixException) receive(QueueKey id, Item item);

Result!(Item, QixException) wait(QueueKey id);

import std.datetime : Duration;;

Result!(Item, QixException) wait(QueueKey id, Duration timeout);

}

Constructors

this this(size_t maxIter): Construct a new queue manager
this this(): Constructs a new queue manager

Members

Functions

newQueue Result!(QueueType*, string) newQueue(): Finds an unused queue id and then instantiates a queue with that id
receive Result!(bool, QixException) receive(QueueKey id, Item item): Pushes a new message into the queue, waking up one of the threads currently blocking to dequeue an item from it
removeQueue bool removeQueue(QueueType* queue): Removes the provided queue from the manager
removeQueue bool removeQueue(QueueKey key): Removes the queue by the provided id from the manager
wait Result!(Item, QixException) wait(QueueKey id): Wait indefinately to dequeue an item from the queue given by the provided id
wait Result!(Item, QixException) wait(QueueKey id, Duration timeout): Wait up until a specified maximum amount of time to dequeue an item from the queue given by the provided id

Meta

Source

See Implementation

qix manager Manager classes

Manager