Function simulate_complex_scheduling

src/tests/rpp/test_scheduler.cpp:74–117

}

static std::string simulate_complex_scheduling(const auto& worker, const auto& obs, std::vector<std::string>& out)
{
    std::thread thread([&, worker] {
        worker.schedule([&, worker](const auto&) {
            out.push_back("Task 1 starts "s + get_thread_id_as_string());

            worker.schedule([&, worker](const auto&, int& counter) -> rpp::schedulers::optional_delay_from_now {
                out.push_back("Task 2 starts "s + get_thread_id_as_string());

                worker.schedule([&](const auto&) {
                    out.push_back("Task 4 runs "s + get_thread_id_as_string());
                    return rpp::schedulers::optional_delay_from_now{};
                },
                                obs);

                out.push_back("Task 2 ends "s + get_thread_id_as_string());
                if (counter++ < 1)
                    return rpp::schedulers::optional_delay_from_now{std::chrono::nanoseconds{1}};
                return std::nullopt;
            },
                            obs,
                            int{});

            worker.schedule([&](const auto&, int& counter) -> rpp::schedulers::optional_delay_from_now {
                out.push_back("Task 3 starts "s + get_thread_id_as_string());

                out.push_back("Task 3 ends "s + get_thread_id_as_string());
                if (counter++ < 1)
                    return rpp::schedulers::optional_delay_from_now{std::chrono::nanoseconds{1}};
                return std::nullopt;
            },
                            obs,
                            int{});

            out.push_back("Task 1 ends "s + get_thread_id_as_string());
            return rpp::schedulers::optional_delay_from_now{};
        },
                        obs);
    });

    auto threadid = get_thread_id_as_string(thread.get_id());
    thread.join();
    return threadid;
}

static std::string simulate_complex_scheduling_with_delay(const auto& worker, const auto& obs, std::vector<std::string>& out)
{