diff --git a/source/eventy/queues.d b/source/eventy/queues.d index 2691f32..9ca7f31 100644 --- a/source/eventy/queues.d +++ b/source/eventy/queues.d @@ -20,6 +20,12 @@ public final class Queue private Mutex queueLock; + this(ulong id) + { + this.id = id; + queueLock = new Mutex(); + } + public void add(Event e) { /* Lock the queue */ @@ -38,7 +44,7 @@ public final class Queue /* Lock the queue */ queueLock.lock(); - has = (queue[]).empty(); + has = !(queue[]).empty(); /* Unlock the queue */ queueLock.unlock();