shifathosn
/
sharpemu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[GPU] Run relay work after accepted command streams 

Co-authored-by: Sekai <140012992+igettingit@users.noreply.github.com>
This commit is contained in:
ParantezTech 2026-10-06 17:47:34 +03:00
parent 83e1ba5235
commit 78902911e9
1 changed files with 45 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
src/SharpEmu.Libs/Gpu/Scheduling/GpuWorkerRelay.cs
View File

@ -14,16 +14,60 @@ public sealed class GpuWorkerRelay : IGpuQueueRelay
private readonly object _gate = new();
private readonly Queue<Action> _commands = new();
private readonly Action _wake;
private readonly Func<Action, Action, bool>? _tryEnqueueAfterPendingWork;
private int _pendingCount;
private bool _accepting = true;
public GpuWorkerRelay(Action wake)
public GpuWorkerRelay(Action wake, Func<Action, Action, bool>? tryEnqueueAfterPendingWork = null)
{
_wake = wake;
_tryEnqueueAfterPendingWork = tryEnqueueAfterPendingWork;
}
public bool TryRunAfterPendingWork(Action work) => TryRunOnGpuQueue(work);
public bool TryRunAfterAcceptedCommandStreams(Action work)
{
ArgumentNullException.ThrowIfNull(work);
if (IsGpuQueueThread || _tryEnqueueAfterPendingWork is null)
{
return TryRunOnGpuQueue(work);
}
using var done = new SemaphoreSlim(0);
System.Runtime.ExceptionServices.ExceptionDispatchInfo? failure = null;
if (!_tryEnqueueAfterPendingWork(
() =>
{
try
{
work();
}
catch (Exception exception)
{
failure = System.Runtime.ExceptionServices.ExceptionDispatchInfo.Capture(exception);
}
finally
{
done.Release();
}
},
() =>
{
failure = System.Runtime.ExceptionServices.ExceptionDispatchInfo.Capture(
new OperationCanceledException(
"The command stream stopped before the ordered GPU worker action could run."));
done.Release();
}))
{
return false;
}
done.Wait();
failure?.Throw();
return true;
}
public bool IsGpuQueueThread => _boundWorker == this;
public bool HasPendingCommands => Volatile.Read(ref _pendingCount) != 0;