From cee712105850ac3385cd0091a923438167433f9f Mon Sep 17 00:00:00 2001
From: TSR Berry <20988865+TSRBerry@users.noreply.github.com>
Date: Sat, 8 Apr 2023 01:22:00 +0200
Subject: Move solution and projects to src

---
 .../Multithreading/Resources/ProgramQueue.cs       | 107 ---------------------
 1 file changed, 107 deletions(-)
 delete mode 100644 Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs

(limited to 'Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs')

diff --git a/Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs b/Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs
deleted file mode 100644
index 3f982d31..00000000
--- a/Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs
+++ /dev/null
@@ -1,107 +0,0 @@
-using Ryujinx.Graphics.GAL.Multithreading.Resources.Programs;
-using System;
-using System.Collections.Generic;
-using System.Threading;
-
-namespace Ryujinx.Graphics.GAL.Multithreading.Resources
-{
-    /// <summary>
-    /// A structure handling multithreaded compilation for programs.
-    /// </summary>
-    class ProgramQueue
-    {
-        private const int MaxConcurrentCompilations = 8;
-
-        private IRenderer _renderer;
-
-        private Queue<IProgramRequest> _toCompile;
-        private List<ThreadedProgram> _inProgress;
-
-        public ProgramQueue(IRenderer renderer)
-        {
-            _renderer = renderer;
-
-            _toCompile = new Queue<IProgramRequest>();
-            _inProgress = new List<ThreadedProgram>();
-        }
-
-        public void Add(IProgramRequest request)
-        {
-            lock (_toCompile)
-            {
-                _toCompile.Enqueue(request);
-            }
-        }
-
-        public void ProcessQueue()
-        {
-            for (int i = 0; i < _inProgress.Count; i++)
-            {
-                ThreadedProgram program = _inProgress[i];
-
-                ProgramLinkStatus status = program.Base.CheckProgramLink(false);
-
-                if (status != ProgramLinkStatus.Incomplete)
-                {
-                    program.Compiled = true;
-                    _inProgress.RemoveAt(i--);
-                }
-            }
-
-            int freeSpace = MaxConcurrentCompilations - _inProgress.Count;
-
-            for (int i = 0; i < freeSpace; i++)
-            {
-                // Begin compilation of some programs in the compile queue.
-                IProgramRequest program;
-
-                lock (_toCompile)
-                {
-                    if (!_toCompile.TryDequeue(out program))
-                    {
-                        break;
-                    }
-                }
-
-                if (program.Threaded.Base != null)
-                {
-                    ProgramLinkStatus status = program.Threaded.Base.CheckProgramLink(false);
-
-                    if (status != ProgramLinkStatus.Incomplete)
-                    {
-                        // This program is already compiled. Keep going through the queue.
-                        program.Threaded.Compiled = true;
-                        i--;
-                        continue;
-                    }
-                }
-                else
-                {
-                    program.Threaded.Base = program.Create(_renderer);
-                }
-
-                _inProgress.Add(program.Threaded);
-            }
-        }
-
-        /// <summary>
-        /// Process the queue until the given program has finished compiling.
-        /// This will begin compilation of other programs on the queue as well.
-        /// </summary>
-        /// <param name="program">The program to wait for</param>
-        public void WaitForProgram(ThreadedProgram program)
-        {
-            Span<SpinWait> spinWait = stackalloc SpinWait[1];
-
-            while (!program.Compiled)
-            {
-                ProcessQueue();
-
-                if (!program.Compiled)
-                {
-                    spinWait[0].SpinOnce(-1);
-                }
-            }
-        }
-    }
-}
-- 
cgit v1.2.3