1 files changed, 62 insertions, 0 deletions
diff --git a/Ryujinx.Graphics.GAL/Multithreading/SyncMap.cs b/Ryujinx.Graphics.GAL/Multithreading/SyncMap.cs
new file mode 100644
index 00000000..ae09e852
--- /dev/null
+++ b/Ryujinx.Graphics.GAL/Multithreading/SyncMap.cs
@@ -0,0 +1,62 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+
+namespace Ryujinx.Graphics.GAL.Multithreading
+{
+    class SyncMap : IDisposable
+    {
+        private HashSet<ulong> _inFlight = new HashSet<ulong>();
+        private AutoResetEvent _inFlightChanged = new AutoResetEvent(false);
+
+        internal void CreateSyncHandle(ulong id)
+        {
+            lock (_inFlight)
+            {
+                _inFlight.Add(id);
+            }
+        }
+
+        internal void AssignSync(ulong id)
+        {
+            lock (_inFlight)
+            {
+                _inFlight.Remove(id);
+            }
+
+            _inFlightChanged.Set();
+        }
+
+        internal void WaitSyncAvailability(ulong id)
+        {
+            // Blocks until the handle is available.
+
+            bool signal = false;
+
+            while (true)
+            {
+                lock (_inFlight)
+                {
+                    if (!_inFlight.Contains(id))
+                    {
+                        break;
+                    }
+                }
+
+                _inFlightChanged.WaitOne();
+                signal = true;
+            }
+
+            if (signal)
+            {
+                // Signal other threads which might still be waiting.
+                _inFlightChanged.Set();
+            }
+        }
+
+        public void Dispose()
+        {
+            _inFlightChanged.Dispose();
+        }
+    }
+}