AsyncPriorityQueue

---

Object Hierarchy:

Description:

Content:

Properties:

• public int waiting_threads { get; }

Creation methods:

• public AsyncPriorityQueue (owned CompareDataFunc? compare_func = null)

Methods:

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

Signals:

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

Inherited Members: