Changeset 190 for binary-improvements/7dtd-server-fixes/src/BlockingQueue.cs

Timestamp:

Sep 13, 2014, 12:55:47 PM (10 years ago)

Author:

alloc

Message:

fixes

File:

• binary-improvements/7dtd-server-fixes/src/BlockingQueue.cs (modified) (3 diffs)

binary-improvements/7dtd-server-fixes/src/BlockingQueue.cs

@@ -7 +7 @@
         public class BlockingQueue<T>
         {
+                private bool closing = false;
                 private Queue<T> queue = new Queue<T> ();
 
@@ -21 +22 @@
                         lock (queue) {
                                 while (queue.Count == 0) {
+                                        if (closing) {
+                                                return default(T);
+                                        }
                                         Monitor.Wait (queue);
                                 }
@@ -27 +31 @@
                 }
 
+                public void Close ()
+                {
+                        lock (queue) {
+                                closing = true;
+                                Monitor.PulseAll (queue);
+                        }
+                }
 
         }