Queue

- Added entrance and exit debugs for `dequeue()`
2023-04-05 08:39:35 +02:00 · 2023-04-05 08:39:35 +02:00 · 883949e555
parent c2e034715d
commit 883949e555
1 changed files with 13 additions and 0 deletions
--- a/source/tristanable/queue.d
+++ b/source/tristanable/queue.d
@ -96,9 +96,22 @@ public class Queue
     */
    public TaggedMessage dequeue()
    {
+        version(unittest)
+        {
+            writeln("queue["~to!(string)(queueID)~"]: Dequeueing...");
+        }
+
        /* The dequeued message */
        TaggedMessage dequeuedMessage;

+        scope(exit)
+        {
+            version(unittest)
+            {
+                writeln("queue["~to!(string)(queueID)~"]: Dequeued '"~to!(string)(dequeuedMessage)~"'!");
+            }
+        }
+
        /* Block till we dequeue a message successfully */
        while(dequeuedMessage is null)
        {