std:: barrier

クラステンプレート std::barrier は、既知のサイズのスレッドグループがバリアに到達するまでそのグループをブロックするスレッド調整メカニズムを提供します。 std::latch とは異なり、バリアは再利用可能です：到着したスレッドグループのブロックが解除されると、バリアは再利用できます。 std::latch とは異なり、バリアはスレッドのブロック解除前に空の可能性もある呼び出し可能オブジェクトを実行します。

バリアオブジェクトのライフタイムは1つ以上のフェーズで構成されます。各フェーズは フェーズ同期ポイント を定義し、待機スレッドはここでブロックします。スレッドはバリアに到着できますが、 arrive を呼び出すことで フェーズ同期ポイント での待機を延期できます。このようなスレッドは後で wait を呼び出すことで フェーズ同期ポイント でブロックできます。

バリアの phase は以下のステップで構成されます:

1. 期待カウント は、 arrive または arrive_and_drop の各呼び出しによってデクリメントされます。
2. 期待カウントがゼロに達すると、 フェーズ完了ステップ が実行されます。つまり、 completion が呼び出され、フェーズ同期ポイントでブロックされているすべてのスレッドがブロック解除されます。完了ステップの終了は、 strongly happens-before 完了ステップによってブロック解除されたすべての呼び出しが戻る前に発生します。
   期待カウントがゼロに達した後、正確に1回、スレッドが arrive 、 arrive_and_drop または wait の呼び出し中に完了ステップを実行します。ただし、どのスレッドも wait を呼び出さない場合にステップが実行されるかどうかは実装定義です。
3. 完了ステップが終了すると、期待カウントは構築時に指定された値から、それ以降の arrive_and_drop の呼び出し回数を減じた値にリセットされ、次の バリアフェーズ が開始されます。

barrier のメンバー関数（デストラクタを除く）の同時呼び出しは、データ競合を引き起こしません。

テンプレートパラメータ

CompletionFunction のデフォルトテンプレート引数は、 さらに DefaultConstructible の要件を満たす未規定の関数オブジェクト型です。 引数なしでその左辺値を呼び出しても効果はありません。

メンバー型

データメンバ

メンバー関数

注記

例

#include <barrier>
#include <iostream>
#include <string>
#include <syncstream>
#include <thread>
#include <vector>
int main()
{
    const auto workers = {"Anil", "Busara", "Carl"};
    auto on_completion = []() noexcept
    {
        // ここではロックは不要
        static auto phase =
            "... done\n"
            "Cleaning up...\n";
        std::cout << phase;
        phase = "... done\n";
    };
    std::barrier sync_point(std::ssize(workers), on_completion);
    auto work = [&](std::string name)
    {
        std::string product = "  " + name + " worked\n";
        std::osyncstream(std::cout) << product;  // OK, op<< 呼び出しはアトミック
        sync_point.arrive_and_wait();
        product = "  " + name + " cleaned\n";
        std::osyncstream(std::cout) << product;
        sync_point.arrive_and_wait();
    };
    std::cout << "Starting...\n";
    std::vector<std::jthread> threads;
    threads.reserve(std::size(workers));
    for (auto const& worker : workers)
        threads.emplace_back(work, worker);
}

Starting...
  Anil worked
  Carl worked
  Busara worked
... done
Cleaning up...
  Busara cleaned
  Carl cleaned
  Anil cleaned
... done

不具合報告

以下の動作変更の欠陥報告書は、以前に公開されたC++規格に対して遡及的に適用されました。

関連項目