5. arrive_and_drop

最終更新日時(UTC):
が更新

履歴 編集

function
<barrier>

std::barrier::arrive_and_drop(C++20)

void arrive_and_drop();

概要

バリアのフェーズ同期ポイントへの到達通知を行い、自スレッドは次フェーズ以降のバリア同期から離脱する。 設定されていれば、次フェーズへの移行前に完了関数を呼び出す。

事前条件

現行バリアフェーズの予定カウントが、0より大きいこと。

効果

全ての後続フェーズの初期予定カウントを1だけ減算する。 その後に、現行フェーズの予定カウントを1だけ減算する。

戻り値

なし

例外

この関数は、以下のerror conditionを持つsystem_error例外オブジェクトを送出する可能性がある：

備考

このメンバ関数呼び出しは、現行フェーズの完了ステップを開始する可能性がある。

例

#include <barrier>
#include <chrono>
#include <iostream>
#include <thread>
#include <utility>

// (ダミーの)タスク処理関数
void do_task(const char* msg)
{
  static std::mutex cout_mtx;

  std::this_thread::sleep_for(std::chrono::seconds(1));
  {
    std::lock_guard lk{cout_mtx};
    std::cout << msg << std::endl;
  }
}

int main()
{
  std::barrier<> sync{3};

  // ワーカスレッド#1起動
  std::thread t1([&]{
    do_task("sub1: phase-1");
    sync.arrive_and_drop();
    // フェーズ#2以降は離脱
  });

  // ワーカスレッド#2起動
  std::thread t2([&]{
    do_task("sub2: phase-1");
    sync.arrive_and_wait();
    do_task("sub2: phase-2");
    sync.arrive_and_drop();
    // フェーズ#3以降は離脱
  });

  // メインスレッド処理
  {
    do_task("main: phase-1");
    sync.arrive_and_wait();
    do_task("main: phase-2");
    sync.arrive_and_wait();
    do_task("main: phase-3");
    sync.arrive_and_wait();
  }

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

出力例

sub2: phase-1
main: phase-1
sub1: phase-1
sub2: phase-2
main: phase-2
main: phase-3

バージョン

言語

  • C++20

処理系

関連項目