diff options
| author | TSR Berry <20988865+TSRBerry@users.noreply.github.com> | 2023-04-08 01:22:00 +0200 |
|---|---|---|
| committer | Mary <thog@protonmail.com> | 2023-04-27 23:51:14 +0200 |
| commit | cee712105850ac3385cd0091a923438167433f9f (patch) | |
| tree | 4a5274b21d8b7f938c0d0ce18736d3f2993b11b1 /Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs | |
| parent | cd124bda587ef09668a971fa1cac1c3f0cfc9f21 (diff) | |
Move solution and projects to src
Diffstat (limited to 'Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs')
| -rw-r--r-- | Ryujinx.Graphics.GAL/Multithreading/Resources/ProgramQueue.cs | 107 |
1 files changed, 0 insertions, 107 deletions
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); - } - } - } - } -} |