Function TEST

tests/cpp/concurrency/thread_safety_test.cpp:28–46

CT001

// CT001
TEST(ConcurrencyTest, CT001_AddRemoveListener_FromMultipleThreads) {
    ::agenui::testing::ScopedSurfaceManager sm;
    ASSERT_TRUE(sm);

    std::vector<std::thread> threads;
    std::vector<::agenui::testing::MockMessageListener> listeners(
        kSpawnedThreads);

    for (int i = 0; i < kSpawnedThreads; ++i) {
        threads.emplace_back([&, i]() {
            for (int k = 0; k < kIterations; ++k) {
                sm->addSurfaceEventListener(&listeners[i]);
                sm->removeSurfaceEventListener(&listeners[i]);
            }
        });
    }
    for (auto& t : threads) t.join();
    ::agenui::testing::WaitForWorkerIdle();
}

// CT002
TEST(ConcurrencyTest, CT002_ReceiveTextChunk_FromMultipleThreads) {