std::jthread(C++20)

#include <iostream>
#include <cstdint>
#include <thread>

std::uint64_t sum1 = 0;
std::uint64_t sum2 = 0;

void f1(std::stop_token stoken, std::uint64_t n)
{
  sum1 = 0;
  for (std::uint64_t i = 1; i < n; ++i) {
    if (stoken.stop_requested()) {
      // 中断リクエストがきたのでスレッドを終了する
      break;
    }
    sum1 += i;
  }
}

void f2(std::uint64_t n)
{
  sum2 = 0;
  for (std::uint64_t i = 1; i < n; ++i) {
    sum2 += i;
  }
}

int main()
{
  {
    // 関数の第1引数がstd::stop_token型である場合、
    // スレッドに中断リクエストを送れるようになる
    std::jthread t1 {f1, 1'000'000};
    std::this_thread::sleep_for(std::chrono::milliseconds{3});
    t1.request_stop(); // スレッドの中断要求を発行

    // スレッド実行する関数がstd::stop_tokenを受け取らない場合、
    // 中断リクエストを使用せず、
    // デストラクタで自動的にjoinするスレッドオブジェクトとして使用する
    std::jthread t2 {
      [] { f2(1'000'000); }
    };
  } // jthreadのデストラクタでは、中断要求を発行し、スレッドの終了を待機する

  std::cout << sum1 << std::endl; // 計算できたところまで表示
  std::cout << sum2 << std::endl;
}

#include <cassert>
#include <thread>

int main()
{
  int x = 0, y = 0;

  std::jthread t([&](std::stop_token st) { x++; });

  // スレッドに対する停止要求の作成に合わせて呼び出される
  // コールバックを定義する。
  std::stop_callback sc { t.get_stop_token(), [&] { y++; }};

  assert(y == 0);

  // 明示的にjoin()を呼び出さずにtを上書きする。
  // このとき、ムーブ代入演算子の呼び出しの中で、
  // 自動で停止要求の作成とjoin()の呼び出しが行われる。
  t = std::jthread{};

  assert(x == 1 && y == 1);

  return 0;
}