jthread, stop_token & Coroutines

1
2
3
4
5
6

std::jthread worker([](std::stop_token st) {
    while (!st.stop_requested()) {
        do_chunk();
    }
});
// worker.request_stop() then join() happen automatically at scope exit

1
2
3
4

void worker(std::stop_token st) {
    std::stop_callback cb(st, []{ std::puts("stopping"); });
    while (!st.stop_requested()) { step(); }
}

1
2
3
4
5
6
7
8
9
10
11
12

Generator<int> fibonacci() {
    int a = 0, b = 1;
    while (true) {
        co_yield a;             // suspend, hand a value out
        auto next = a + b; a = b; b = next;
    }
}

Task<Response> fetch(Url u) {
    auto conn = co_await connect(u);   // suspend without blocking a thread
    co_return co_await conn.read();
}