#include <iostream>
#include <thread>
#include <chrono>

std::mutex cout_mutex;

void count_up(std::stop_token st, int id) {
    int i = 0;
    while (not st.stop_requested()) {  // 停止要求の監視が必要
        std::lock_guard lock{ cout_mutex };  // mutex などによる排他制御が必要
        std::cout << "task(" << id << "): " << i++ << '\n';
    }
}

int main() {
    using namespace std::literals::chrono_literals;

    std::jthread task1{ count_up, 1 };
    std::jthread task2{ count_up, 2 };

    std::this_thread::sleep_for(1ms);
}

#include <iostream>
#include <chrono>
#include "CoroAsync/Task.hpp"
#include "CoroAsync/TaskQueue.hpp"

cra::Task<> count_up(int id) {
    int i = 0;
    while (true) {  // 停止要求の監視は不要
        std::cout << "task(" << id << "): " << i++ << '\n';
        co_await 0;  // mutex などによる排他制御は必要、 co_await 以外で割り込まれない
    }
}

int main() {
    using namespace std::literals::chrono_literals;

    auto task1 = count_up(1);
    auto task2 = count_up(2);

    cra::TaskQueue::RunFor(1ms);
}