diff options
| author | liamwhite <liamwhite@users.noreply.github.com> | 2023-03-23 10:00:31 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-03-23 10:00:31 -0400 |
| commit | ac3927074b190965bacbf99f70e8c5e95c953788 (patch) | |
| tree | 324b95f908f83dde8b1b78cde131a8145f032508 /src/video_core/gpu_thread.cpp | |
| parent | c41a4baf06efe935f08331bc6f8ff6d80dc088f5 (diff) | |
| parent | 197d7565603b2e8274f5c176f73b468ce6aa46a6 (diff) | |
Merge pull request #9971 from Morph1984/q
bounded_threadsafe_queue: Use simplified impl of bounded queue
Diffstat (limited to 'src/video_core/gpu_thread.cpp')
| -rw-r--r-- | src/video_core/gpu_thread.cpp | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/video_core/gpu_thread.cpp b/src/video_core/gpu_thread.cpp index f52f9e28fa..3c5317777f 100644 --- a/src/video_core/gpu_thread.cpp +++ b/src/video_core/gpu_thread.cpp @@ -31,9 +31,10 @@ static void RunThread(std::stop_token stop_token, Core::System& system, auto current_context = context.Acquire(); VideoCore::RasterizerInterface* const rasterizer = renderer.ReadRasterizer(); + CommandDataContainer next; + while (!stop_token.stop_requested()) { - CommandDataContainer next; - state.queue.Pop(next, stop_token); + state.queue.PopWait(next, stop_token); if (stop_token.stop_requested()) { break; } @@ -117,7 +118,7 @@ u64 ThreadManager::PushCommand(CommandData&& command_data, bool block) { std::unique_lock lk(state.write_lock); const u64 fence{++state.last_fence}; - state.queue.Push(CommandDataContainer(std::move(command_data), fence, block)); + state.queue.EmplaceWait(std::move(command_data), fence, block); if (block) { Common::CondvarWait(state.cv, lk, thread.get_stop_token(), [this, fence] { |