diff --git a/Source/UnitTests/Common/CMakeLists.txt b/Source/UnitTests/Common/CMakeLists.txt index e509f160f2..3b0ffe79e6 100644 --- a/Source/UnitTests/Common/CMakeLists.txt +++ b/Source/UnitTests/Common/CMakeLists.txt @@ -19,6 +19,7 @@ add_dolphin_test(SettingsHandlerTest SettingsHandlerTest.cpp) add_dolphin_test(SPSCQueueTest SPSCQueueTest.cpp) add_dolphin_test(StringUtilTest StringUtilTest.cpp) add_dolphin_test(SwapTest SwapTest.cpp) +add_dolphin_test(WorkQueueThreadTest WorkQueueThreadTest.cpp) if (_M_X86_64) add_dolphin_test(x64EmitterTest x64EmitterTest.cpp) diff --git a/Source/UnitTests/Common/WorkQueueThreadTest.cpp b/Source/UnitTests/Common/WorkQueueThreadTest.cpp new file mode 100644 index 0000000000..a4bfc654f2 --- /dev/null +++ b/Source/UnitTests/Common/WorkQueueThreadTest.cpp @@ -0,0 +1,53 @@ +// Copyright 2025 Dolphin Emulator Project +// SPDX-License-Identifier: GPL-2.0-or-later + +#include + +#include "Common/WorkQueueThread.h" + +TEST(WorkQueueThread, Simple) +{ + Common::WorkQueueThreadSP worker; + + constexpr int BIG_VAL = 1000; + + int x = 0; + const auto func = [&](int value) { x = value; }; + + worker.Push(1); + worker.WaitForCompletion(); + // Still zero because it's not running. + EXPECT_EQ(x, 0); + + // Does nothing if not running. + worker.Shutdown(); + + worker.Reset("test worker", func); + worker.WaitForCompletion(); + // Items pushed before Reset are processed. + EXPECT_EQ(x, 1); + + worker.Shutdown(); + worker.Push(0); + worker.WaitForCompletion(); + // Still 1 because it's no longer running. + EXPECT_EQ(x, 1); + + worker.Cancel(); + worker.Reset("test worker", func); + worker.WaitForCompletion(); + // Still 1 because the work was canceled. + EXPECT_EQ(x, 1); + + for (int i = 0; i != BIG_VAL; ++i) + worker.Push(i); + worker.Cancel(); + // Could be any one of the pushed values. + EXPECT_LT(x, BIG_VAL); + GTEST_LOG_(INFO) << "Canceled work after item " << x; + + worker.Push(2); + worker.WaitForCompletion(); + // Still running after cancelation. + EXPECT_EQ(x, 2); +} diff --git a/Source/UnitTests/UnitTests.vcxproj b/Source/UnitTests/UnitTests.vcxproj index 45702ed7fd..b5e5256915 100644 --- a/Source/UnitTests/UnitTests.vcxproj +++ b/Source/UnitTests/UnitTests.vcxproj @@ -58,6 +58,7 @@ + @@ -118,4 +119,4 @@ - \ No newline at end of file +