Function TEST_F

async_simple/coro/test/ConditionVariableTest.cpp:44–74

};

TEST_F(ConditionVariableTest, testSingleWait) {
    auto data = 0;
    Notifier notifier;
    std::atomic<size_t> latch(2);

    executors::SimpleExecutor e1(1);
    executors::SimpleExecutor e2(1);

    auto producer = [&]() -> Lazy<void> {
        data = 1;
        CHECK_EXECUTOR(&e2);
        notifier.notify();
        CHECK_EXECUTOR(&e2);
        co_return;
    };
    auto awaiter = [&]() -> Lazy<void> {
        CHECK_EXECUTOR(&e1);
        co_await notifier.wait();
        CHECK_EXECUTOR(&e1);
        EXPECT_EQ(1, data);
        data = 2;
        co_return;
    };
    awaiter().via(&e1).start(
        [&](Try<void> var) { latch.fetch_sub(1u, std::memory_order_relaxed); });
    producer().via(&e2).start(
        [&](Try<void> var) { latch.fetch_sub(1u, std::memory_order_relaxed); });
    while (latch.load(std::memory_order_relaxed))
        ;
    EXPECT_EQ(2, data);
}

TEST_F(ConditionVariableTest, testMultiWait) {
    auto data = 0;