Function Uthread_async

benchmarks/Uthread.bench.cpp:75–108

}

void Uthread_async(benchmark::State& state) {
    async_simple::executors::SimpleExecutor executor(10);
    auto test = [&]() {
        auto Job = [&]() -> Future<int> {
            Promise<int> p;
            auto f = p.getFuture().via(&executor);
            delayedTask(
                &executor,
                [p = std::move(p)]() mutable {
                    auto value = 1024;
                    p.setValue(value);
                },
                100);
            return f;
        };

        constexpr size_t n = 10;
        std::atomic<int> running = n;

        for (size_t i = 0; i < n; i++)
            async<Launch::Schedule>(
                [&running, &Job]() {
                    await(Job());
                    running--;
                },
                &executor);

        while (running) {
        }
    };

    for ([[maybe_unused]] const auto& _ : state)
        test();
}

void Uthread_await(benchmark::State& state) {
    async_simple::executors::SimpleExecutor executor(10);