Execution control library (since C++26)

実行制御ライブラリは、汎用的な実行リソース上での非同期実行を管理するためのフレームワークを提供します。

このライブラリは、非同期操作のための語彙型を提供し、タスク実行グラフをシンプルで合成可能な方法で構築することを目的としています。

ライブラリ全体の定義

• Sender : 非同期処理の実行のために送信される作業の記述。操作状態（下記）を生成する。

• 送信者は非同期にその結果を「レシーバー」（下記）と呼ばれるリスナーに「送信」します。
• 送信者はジェネリックアルゴリズムを使用して タスクグラフ に構成できます。
• 送信者ファクトリーとアダプター は、 sender コンセプトを満たすオブジェクト内で一般的な非同期パターンを捕捉するジェネリックアルゴリズムです。

• Receiver : 非同期操作によって生成された結果を消費または「受信」する汎用コールバック。

• レシーバーは、送信者が結果を伝播するための3つの異なる「チャネル」を持っています：成功、失敗、キャンセル。これらはそれぞれ「値」、「エラー」、「停止」と呼ばれます。
• レシーバーは拡張可能な実行環境を提供します：消費者が非同期操作をパラメータ化するために使用できるキーと値のペアのセットです。

• 操作状態 : 非同期操作で必要とされる状態を含むオブジェクト。

• 送信者とレシーバーは、 std::execution::connect 関数に渡されたときに接続されます。
• 送信者とレシーバーを接続した結果は、オペレーション状態です。
• オペレーション状態に対して「 start 」が呼び出されるまで、実行のためのワークはエンキューされません。
• 一度開始されると、非同期オペレーションが完了する前にオペレーション状態の寿命が終了することはなく、そのアドレスは安定している必要があります。

• Scheduler : 実行コンテキストへの軽量なハンドル。

• 実行コンテキストは、スレッドプールやGPUストリームなどの非同期実行のソースです。
• スケジューラは、実行コンテキストが所有する実行スレッドからそのレシーバーを完了させる送信者のファクトリです。

ライブラリユーティリティ

コンセプト

スケジューラ

送信者

レシーバー

操作状態

ユーティリティコンポーネント

実行コンテキスト

実行ドメイン

前方進行保証

環境

クエリ

完了シグネチャ

コルーチン ユーティリティ

コア操作

動作状態

完了関数

これらの関数は、送信側が受信側に対して作業の完了を通知するために呼び出されます。

送信側アルゴリズム

Senderファクトリ

送信者ファクトリは送信者を返す関数であり、そのパラメータの型に対して sender コンセプトが false となるものです。

以下は送信者ファクトリです：

パイプ可能なセンダーアダプタ

送信者アダプタ

送信者アダプタは、少なくとも1つのパラメータの型が sender コンセプトを満たす送信者を返す関数であり、返される送信者はアダプタ関数の送信者引数の親送信者となります。

以下は送信側アダプタです：

送信者コンシューマ

送信者コンシューマは、1つ以上の送信者をパラメータとして受け取り、送信者を返さないアルゴリズムです。

例

#include <cstdio>
#include <execution>
#include <string>
#include <thread>
#include <utility>
using namespace std::literals;
int main()
{
    std::execution::run_loop loop;
    std::jthread worker([&](std::stop_token st)
    {
        std::stop_callback cb{st, [&]{ loop.finish(); }};
        loop.run();
    });
    std::execution::sender auto hello = std::execution::just("hello world"s);
    std::execution::sender auto print
        = std::move(hello)
        | std::execution::then([](std::string msg)
        {
            return std::puts(msg.c_str());
        });
    std::execution::scheduler auto io_thread = loop.get_scheduler();
    std::execution::sender auto work = std::execution::on(io_thread, std::move(print));
    auto [result] = std::this_thread::sync_wait(std::move(work)).value();
    return result;
}

hello world

関連項目