std::execution::scheduler

 

C++

コンパイラサポート

フリースタンディングとホスト

言語

標準ライブラリ

標準ライブラリヘッダー

名前付き要件

機能テストマクロ (C++20)

言語サポートライブラリ

コンセプトライブラリ (C++20)

診断ライブラリ

メモリ管理ライブラリ

メタプログラミングライブラリ (C++11)

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

コンテナライブラリ

イテレータライブラリ

Rangesライブラリ (C++20)

アルゴリズムライブラリ

文字列ライブラリ

テキスト処理ライブラリ

数値ライブラリ

日付と時刻ライブラリ

入出力ライブラリ

ファイルシステムライブラリ (C++17)

並行サポートライブラリ (C++11)

実行制御ライブラリ (C++26)

Technical specifications (技術仕様)

シンボルインデックス

外部ライブラリ

 

実行制御ライブラリ

実行コンセプト scheduler receiver receiver_of operation_state    sender sender_in sender_to 実行コンポーネント 実行コンテキスト run_loop 実行ドメイン default_domain 前方進行保証 forward_progress_guarantee 環境 empty_env    get_env    env_of_t 問い合わせ std::stop_token_of_t std::get_stop_token std::get_allocator std::forwarding_query get_scheduler get_domain get_forward_progress_guarantee get_delegation_scheduler get_completion_scheduler 完了シグネチャ completion_signatures completion_signatures_of_t transform_completion_signatures transform_completion_signatures_of    value_types_of_t error_types_of_t    tag_of_t sends_stopped    Senderアダプタクロージャ sender_adaptor_closure コルーチンユーティリティ as_awaitable with_awaitable_senders

中核操作 操作状態 connect connect_result_t start 完了 set_value set_error set_stopped 変換 transform_env transform_sender apply_sender Senderアルゴリズム Senderファクトリ just just_error just_stopped read_env schedule schedule_result_t Senderアダプタ starts_on continues_on    on then upon_error upon_stopped let_value let_error let_stopped schedule_from when_all when_all_with_variant into_variant stopped_as_optional stopped_as_error bulk split Senderコンシューマ this_thread::sync_wait this_thread::sync_wait_with_variant

 

ヘッダ <execution> で定義
template< class Sch > concept scheduler =     std::derived_from<         typename std::remove_cvref_t<Sch>::scheduler_concept,         scheduler_t> &&     /*queryable*/<Sch> &&     requires(Sch&& sch)     {         {             std::execution::schedule(std::forward<Sch>(sch))         } -> std::execution::sender;         {             auto(                 std::execution::get_completion_scheduler<                     std::execution::set_value_t>(                         std::execution::get_env(                             std::execution::schedule(                                 std::forward<Sch>(sch)))))         } -> std::same_as<std::remove_cvref_t<Sch>>;     } &&     std::equality_comparable<std::remove_cvref_t<Sch>> &&     std::copy_constructible<std::remove_cvref_t<Sch>>; };	(1)	(C++26以降)
Helper tag type
struct scheduler_t {};	(2)	(C++26以降)

Concept scheduler は、C++実行ライブラリで動作するスレッドプールなどの実行リソースへの軽量ハンドラである「スケジューラ」を表す型によってモデル化されます。

意味要件

型 Sch のスケジューラと、sender_in<schedule_result_t<Sch>, Env> が満たされるような型 Env の実行環境が与えられた場合、/*sender-in-of*/<schedule_result_t<Sch>, Env> がモデル化されます。

スケジューラのコピーコンストラクタ、デストラクタ、等価比較、またはスワップメンバ関数は非例外的である必要があります。

これらのメンバ関数すべて、およびスケジューラ型の schedule 関数はスレッドセーフである必要があります。

2つのスケジューラは、それらが同じ実行リソースを表す場合にのみ等しくなります。

指定されたスケジューラ sch に対して、式 get_completion_scheduler<set_value_t>(get_env(schedule(sch))) は sch と等価比較されます。

指定されたスケジューラ sch に対して、式 get_domain(sch) が well-formed である場合、式 get_domain(get_env(schedule(sch))) も well-formed であり、同じ型を持ちます。

スケジューラのデストラクタは、schedule から返されたセーダーオブジェクトに接続されたレシーバの保留中の完了をブロックしてはなりません（基盤となるリソースは、サブミットされた関数オブジェクトの完了を待機するための個別のAPIを提供する場合があります）。

例

std::execution::run_loop の簡単なラッパーで、単一の専用スレッドで run_loop のキューを継続的にポーリングします。ドラフト参照実装を使用したデモ: https://godbolt.org/z/146fY4Y91

このコードを実行

#include <execution>
#include <iostream>
#include <thread>
 
class single_thread_context
{
    std::execution::run_loop loop_{};
    std::jthread thread_;
 
public:
    single_thread_context()
        : thread_([this] { loop_.run(); })
    {}
    single_thread_context(single_thread_context&&) = delete;
 
    ~single_thread_context()
    {
        loop_.finish();
    }
 
    std::execution::scheduler auto get_scheduler() noexcept
    {
        return loop_.get_scheduler();
    }
};
 
int main()
{
    single_thread_context ctx;
 
    std::execution::sender auto snd =
        std::execution::schedule(ctx.get_scheduler())
        | std::execution::then([]
            {
                std::cout << "Hello world! Have an int.\n";
                return 015;
            })
        | std::execution::then([](int arg) { return arg + 42; });
 
    auto [i] = std::this_thread::sync_wait(snd).value();
 
    std::cout << "Back in the main thread, result is " << i << '\n';
}

出力

Hello world! Have an int.
Back in the main thread, result is 55

関連項目

execution::schedule (C++26)

指定されたスケジューラで実行するためのタスクグラフを準備します。 (カスタマイズポイントオブジェクト)