MessageManager

- Try using a `SmartPolicy`-based queue
2023-11-22 14:31:56 +02:00 · 2023-11-22 14:31:56 +02:00 · 99d08ff899
parent 57b4f930b0
commit 99d08ff899
1 changed files with 4 additions and 2 deletions
--- a/source/renaissance/server/messagemanager.d
+++ b/source/renaissance/server/messagemanager.d
@ -232,8 +232,10 @@ public class MessageManager
    private this()
    {
        // Initialize the queues (send+receive)
-        this.sendQueue = new Queue();
-        this.receiveQueue = new Queue();
+        // this.sendQueue = new Queue();
+        // this.receiveQueue = new Queue();
+        this.sendQueue = Queue.makeSmart();
+        this.receiveQueue = Queue.makeSmart();
    }

    public void sendq(Message message)