std::stop_source::request_stop

#include <cassert>
#include <stop_token>
#include <condition_variable>
#include <mutex>
#include <thread>

int main()
{
  {
    std::stop_source ss1;
    std::stop_source ss2(std::nostopstate);

    assert(ss1.request_stop() == true);

    // 二度目以降の停止要求は効果を持たない
    assert(ss1.request_stop() == false);

    // 停止状態を所有していない stop_source に対しては
    // 停止要求を作成できない
    assert(ss2.request_stop() == false);
  }

  {
    std::stop_source ss;

    // コールバックを登録
    bool b1 = false;
    std::stop_callback cb1 { ss.get_token(), [&] { b1 = true; } };

    // コールバックを登録
    bool b2 = false;
    std::stop_callback cb2 { ss.get_token(), [&] { b2 = true; } };

    assert(b1 == false && b2 == false);

    // この中で、 ss が所有している停止状態に対して登録されている
    // すべてのコールバックが呼び出される
    ss.request_stop();

    assert(b1 == true && b2 == true);
  }

  {
    std::stop_source ss;
    std::mutex mtx;

    auto cv_wait_test_func = [&] {
      // 待機を終了するための条件を表す述語。
      // この述語は常に false を返すため、永久に待機し続けることを意味する。
      auto wait_forever = [] { return false; };

      std::condition_variable_any cv;
      std::unique_lock lock { mtx };

      // 割り込み可能な待機処理を行う。
      // 割り込み可能な待機関数は、停止要求によって起床通知が送られたときに、
      // 述語が返す値に関わらず待機関数から処理を戻す。
      cv.wait(lock, ss.get_token(), wait_forever);
    };

    std::thread t1(cv_wait_test_func);
    std::thread t2(cv_wait_test_func);

    std::this_thread::sleep_for(std::chrono::milliseconds(100));

    // 停止要求を作成すると、ss が所有する停止状態を利用して割り込み可能な待機処理を行っている
    // すべての condition_variable_any に対して、起床通知が送られる。
    ss.request_stop();

    t1.join();
    t2.join();
  }
}