1 files changed, 63 insertions, 0 deletions
diff --git a/Software/Visual_Studio/SideChains/RealTimeGraphXNet/RealTimeGraphX/GraphDataQueue.cs b/Software/Visual_Studio/SideChains/RealTimeGraphXNet/RealTimeGraphX/GraphDataQueue.cs
new file mode 100644
index 000000000..cb28231ab
--- /dev/null
+++ b/Software/Visual_Studio/SideChains/RealTimeGraphXNet/RealTimeGraphX/GraphDataQueue.cs
@@ -0,0 +1,63 @@
+using System;
+using System.Collections.Concurrent;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace RealTimeGraphX
+{
+    /// <summary>
+    /// Represents a blocking concurrent queue for graph data consumption.
+    /// </summary>
+    /// <typeparam name="T"></typeparam>
+    /// <seealso cref="System.Collections.Concurrent.BlockingCollection{T}" />
+    public class GraphDataQueue<T> : BlockingCollection<T>
+    {
+        /// <summary>
+        /// Initializes a new instance of the GraphDataQueue, Use Add and TryAdd for Enqueue and TryEnqueue and Take and TryTake for Dequeue and TryDequeue functionality
+        /// </summary>
+        public GraphDataQueue()
+            : base(new ConcurrentQueue<T>())
+        {
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the GraphDataQueue, Use Add and TryAdd for Enqueue and TryEnqueue and Take and TryTake for Dequeue and TryDequeue functionality
+        /// </summary>
+        /// <param name="maxSize"></param>
+        public GraphDataQueue(int maxSize)
+            : base(new ConcurrentQueue<T>(), maxSize)
+        {
+        }
+
+        /// <summary>
+        /// Enqueues the specified item.
+        /// </summary>
+        /// <param name="item">The item.</param>
+        public void BlockEnqueue(T item)
+        {
+            Add(item);
+        }
+
+        /// <summary>
+        /// Blocks until an item is available for dequeuing.
+        /// </summary>
+        /// <returns></returns>
+        public T BlockDequeue()
+        {
+            return Take();
+        }
+
+        /// <summary>
+        /// Blocks until an item is available for dequeuing.
+        /// </summary>
+        /// <param name="cancellationToken">The cancellation token.</param>
+        /// <returns></returns>
+        public T BlockDequeue(CancellationToken cancellationToken)
+        {
+            return Take(cancellationToken);
+        }
+    }
+}