AsyncPriorityQueue

AsyncPriorityQueue

Object Hierarchy:

Description:

public class AsyncPriorityQueue<G> : PriorityQueue<G>

Priority queue for asynchronous communications

This is basically just a layer on top of GeePriorityQueue to provide thread safety and blocking peek and poll methods, similar to how GAsyncQueue adds functionality to GQueue.

Namespace: Bump

Package: bump-0.1

Content:

Properties:

public int waiting_threads { set; get; }

Creation methods:

public AsyncPriorityQueue (owned CompareDataFunc? compare_func = null)

Methods:

public G poll_timed (TimeSpan wait = -1)
Poll the queue, blocking until timeout or data is received
public override G poll ()
public G peek_timed (TimeSpan wait = -1)
Peek on the queue, blocking until timeout or data is received
public override G peek ()
public override bool offer (G element)
public override void foreach (ForallFunc<G> f)

Signals:

public signal void consumer_shortage ()
Data was added to the queue but no consumers were waiting.