diff options
author | Ameer J <52414509+ameerj@users.noreply.github.com> | 2021-07-09 01:20:57 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-07-09 01:20:57 +0200 |
commit | 975a7b3a78af40f05b92a53a96b9dcd7e85969e4 (patch) | |
tree | 56196b303ab9dd7f138beb45c471169647e1144a /src/common/thread_worker.cpp | |
parent | Merge pull request #6539 from lat9nq/default-setting (diff) | |
parent | common/thread_worker: Stop workers on stop_token when waiting (diff) | |
download | yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.tar yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.tar.gz yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.tar.bz2 yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.tar.lz yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.tar.xz yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.tar.zst yuzu-975a7b3a78af40f05b92a53a96b9dcd7e85969e4.zip |
Diffstat (limited to 'src/common/thread_worker.cpp')
-rw-r--r-- | src/common/thread_worker.cpp | 58 |
1 files changed, 0 insertions, 58 deletions
diff --git a/src/common/thread_worker.cpp b/src/common/thread_worker.cpp deleted file mode 100644 index 8f9bf447a..000000000 --- a/src/common/thread_worker.cpp +++ /dev/null @@ -1,58 +0,0 @@ -// Copyright 2020 yuzu emulator team -// Licensed under GPLv2 or any later version -// Refer to the license.txt file included. - -#include "common/thread.h" -#include "common/thread_worker.h" - -namespace Common { - -ThreadWorker::ThreadWorker(std::size_t num_workers, const std::string& name) { - for (std::size_t i = 0; i < num_workers; ++i) - threads.emplace_back([this, thread_name{std::string{name}}] { - Common::SetCurrentThreadName(thread_name.c_str()); - - // Wait for first request - { - std::unique_lock lock{queue_mutex}; - condition.wait(lock, [this] { return stop || !requests.empty(); }); - } - - while (true) { - std::function<void()> task; - - { - std::unique_lock lock{queue_mutex}; - condition.wait(lock, [this] { return stop || !requests.empty(); }); - if (stop || requests.empty()) { - return; - } - task = std::move(requests.front()); - requests.pop(); - } - - task(); - } - }); -} - -ThreadWorker::~ThreadWorker() { - { - std::unique_lock lock{queue_mutex}; - stop = true; - } - condition.notify_all(); - for (std::thread& thread : threads) { - thread.join(); - } -} - -void ThreadWorker::QueueWork(std::function<void()>&& work) { - { - std::unique_lock lock{queue_mutex}; - requests.emplace(work); - } - condition.notify_one(); -} - -} // namespace Common |