diff options
| author | Jordan Woyak <jordan.woyak@gmail.com> | 2025-04-29 20:21:08 -0500 |
|---|---|---|
| committer | Jordan Woyak <jordan.woyak@gmail.com> | 2025-05-01 22:55:23 -0500 |
| commit | 4e736d60db295c0700fa1391b473544a9cb5ed72 (patch) | |
| tree | 573f9aa7d7566fa3590b874d87280fca6db98e1b /Source/Core/AudioCommon | |
| parent | be4b0af971b179abcd00107aa6f3c018a462b8bc (diff) | |
Core and AudioCommon: Use AsyncWorkThread.
Diffstat (limited to 'Source/Core/AudioCommon')
| -rw-r--r-- | Source/Core/AudioCommon/CubebStream.cpp | 12 | ||||
| -rw-r--r-- | Source/Core/AudioCommon/CubebStream.h | 2 |
2 files changed, 7 insertions, 7 deletions
diff --git a/Source/Core/AudioCommon/CubebStream.cpp b/Source/Core/AudioCommon/CubebStream.cpp index 92ab886580..4f97b9edd6 100644 --- a/Source/Core/AudioCommon/CubebStream.cpp +++ b/Source/Core/AudioCommon/CubebStream.cpp @@ -39,10 +39,10 @@ void CubebStream::StateCallback(cubeb_stream* stream, void* user_data, cubeb_sta CubebStream::CubebStream() #ifdef _WIN32 - : m_work_queue("Cubeb Worker", [](const std::function<void()>& func) { func(); }) + : m_work_queue("Cubeb Worker") { Common::Event sync_event; - m_work_queue.EmplaceItem([this, &sync_event] { + m_work_queue.Push([this, &sync_event] { Common::ScopeGuard sync_event_guard([&sync_event] { sync_event.Set(); }); auto result = ::CoInitializeEx(nullptr, COINIT_MULTITHREADED | COINIT_DISABLE_OLE1DDE); m_coinit_success = result == S_OK; @@ -62,7 +62,7 @@ bool CubebStream::Init() if (!m_coinit_success) return false; Common::Event sync_event; - m_work_queue.EmplaceItem([this, &return_value, &sync_event] { + m_work_queue.Push([this, &return_value, &sync_event] { Common::ScopeGuard sync_event_guard([&sync_event] { sync_event.Set(); }); #endif @@ -113,7 +113,7 @@ bool CubebStream::SetRunning(bool running) if (!m_coinit_success) return false; Common::Event sync_event; - m_work_queue.EmplaceItem([this, running, &return_value, &sync_event] { + m_work_queue.Push([this, running, &return_value, &sync_event] { Common::ScopeGuard sync_event_guard([&sync_event] { sync_event.Set(); }); #endif if (running) @@ -132,7 +132,7 @@ CubebStream::~CubebStream() { #ifdef _WIN32 Common::Event sync_event; - m_work_queue.EmplaceItem([this, &sync_event] { + m_work_queue.Push([this, &sync_event] { Common::ScopeGuard sync_event_guard([&sync_event] { sync_event.Set(); }); #endif cubeb_stream_stop(m_stream); @@ -156,7 +156,7 @@ void CubebStream::SetVolume(int volume) if (!m_coinit_success) return; Common::Event sync_event; - m_work_queue.EmplaceItem([this, volume, &sync_event] { + m_work_queue.Push([this, volume, &sync_event] { Common::ScopeGuard sync_event_guard([&sync_event] { sync_event.Set(); }); #endif cubeb_stream_set_volume(m_stream, volume / 100.0f); diff --git a/Source/Core/AudioCommon/CubebStream.h b/Source/Core/AudioCommon/CubebStream.h index 72d7d1c117..a523d65441 100644 --- a/Source/Core/AudioCommon/CubebStream.h +++ b/Source/Core/AudioCommon/CubebStream.h @@ -39,7 +39,7 @@ private: std::vector<float> m_floatstereo_buffer; #ifdef _WIN32 - Common::WorkQueueThread<std::function<void()>> m_work_queue; + Common::AsyncWorkThread m_work_queue; bool m_coinit_success = false; bool m_should_couninit = false; #endif |