Function FL_TEST_FILE

tests/platforms/coroutine.cpp:23–135

#include "fl/system/engine_events.h"

FL_TEST_FILE(FL_FILEPATH) {

using namespace fl;
using fl::task::CoroutineConfig;
using fl::task::run;
using fl::task::Scheduler;

// ============================================================
// Level 1: Binary semaphore tests
// ============================================================

FL_TEST_CASE("coroutine - binary semaphore basic signal") {
    fl::binary_semaphore sem(0);
    FL_CHECK_FALSE(sem.try_acquire());
    sem.release();
    FL_CHECK(sem.try_acquire());
    FL_CHECK_FALSE(sem.try_acquire());
}

FL_TEST_CASE("coroutine - binary semaphore thread handoff") {
    fl::binary_semaphore sem(0);
    fl::atomic<bool> thread_ran(false);

    fl::thread t([&]() {
        sem.acquire();
        thread_ran.store(true);
    });

    fl::this_thread::sleep_for(fl::chrono::milliseconds(10)); // ok sleep for
    FL_CHECK_FALSE(thread_ran.load());

    sem.release();
    t.join();
    FL_CHECK(thread_ran.load());
}

FL_TEST_CASE("coroutine - counting semaphore two-phase handoff") {
    fl::counting_semaphore<2> sem(0);
    fl::atomic<int> phase(0);

    fl::thread t([&]() {
        phase.store(1);
        sem.release();  // Signal "started"

        // Simulate work
        fl::this_thread::sleep_for(fl::chrono::milliseconds(5)); // ok sleep for

        phase.store(2);
        sem.release();  // Signal "done"
    });

    sem.acquire();  // Wait for "started"
    FL_CHECK_EQ(phase.load(), 1);

    sem.acquire();  // Wait for "done"
    FL_CHECK_EQ(phase.load(), 2);

    t.join();