Unittests: Add BlockingLoopTest

Source/UnitTests/Common/BlockingLoopTest.cpp

@@ -0,0 +1,59 @@
+// Copyright 2014 Dolphin Emulator Project
+// Licensed under GPLv2+
+// Refer to the license.txt file included.
+
+#include <atomic>
+#include <thread>
+
+#include <gtest/gtest.h>
+
+#include "Common/BlockingLoop.h"
+
+
+TEST(BlockingLoop, MultiThreaded)
+{
+	Common::BlockingLoop loop;
+	std::atomic<int> signaled(0);
+	std::atomic<int> received(0);
+	for (int i = 0; i < 100; i++)
+	{
+		// Invalidate the current state.
+		received.store(signaled.load() + 1);
+
+		// Must not block as the loop is stopped.
+		loop.Wait();
+
+		std::thread loop_thread(
+		[&]() {
+			loop.Run(
+			[&]() {
+				received.store(signaled.load());
+			}
+			);
+		});
+
+		// Now Wait must block.
+		loop.Prepare();
+
+		// The payload must run at least once on startup.
+		loop.Wait();
+		EXPECT_EQ(signaled.load(), received.load());
+
+		for (int j = 0; j < 100; j++)
+		{
+			for (int k = 0; k < 100; k++)
+			{
+				signaled++;
+				loop.Set();
+			}
+
+			loop.Wait();
+			EXPECT_EQ(signaled.load(), received.load());
+		}
+
+		loop.Stop();
+
+		loop_thread.join();
+	}
+}
+

Source/UnitTests/Common/CMakeLists.txt

@@ -1,5 +1,6 @@
 add_dolphin_test(BitFieldTest BitFieldTest.cpp)
 add_dolphin_test(BitSetTest BitSetTest.cpp)
+add_dolphin_test(BlockingLoopTest BlockingLoopTest.cpp)
 add_dolphin_test(CommonFuncsTest CommonFuncsTest.cpp)
 add_dolphin_test(EventTest EventTest.cpp)
 add_dolphin_test(FifoQueueTest FifoQueueTest.cpp)