1 files changed, 33 insertions, 0 deletions

diff --git a/OpenGridServices/OpenGridServices.Manager/OpenGridServices.Manager/BlockingQueue.cs b/OpenGridServices/OpenGridServices.Manager/OpenGridServices.Manager/BlockingQueue.cs
new file mode 100644
index 0000000..83685fc
--- /dev/null
+++ b/OpenGridServices/OpenGridServices.Manager/OpenGridServices.Manager/BlockingQueue.cs
@@ -0,0 +1,33 @@
+using System;

+using System.Threading;

+using System.Collections.Generic;

+using System.Text;

+

+namespace OpenGridServices.Manager

+{

+    public class BlockingQueue<T>

+    {

+        private Queue<T> _queue = new Queue<T>();

+        private object _queueSync = new object();

+

+        public void Enqueue(T value)

+        {

+            lock (_queueSync)

+            {

+                _queue.Enqueue(value);

+                Monitor.Pulse(_queueSync);

+            }

+        }

+

+        public T Dequeue()

+        {

+            lock (_queueSync)

+            {

+                if (_queue.Count < 1)

+                    Monitor.Wait(_queueSync);

+

+                return _queue.Dequeue();

+            }

+        }

+    }

+}