std::execution::scheduler

 

C++

編譯器支援

自由（freestanding）與宿主（hosted）

語言

標準庫

標準庫標頭檔案

具名要求

特性測試宏 (C++20)

語言支援庫

概念庫 (C++20)

診斷庫

記憶體管理庫

超程式設計庫 (C++11)

通用工具庫

容器庫

迭代器庫

範圍庫 (C++20)

演算法庫

字串庫

文字處理庫

數值庫

日期和時間庫

輸入/輸出庫

檔案系統庫 (C++17)

併發支援庫 (C++11)

執行控制庫 (C++26)

技術規範

符號索引

外部庫

 

執行控制庫

執行概念 排程器 接收器 receiver_of operation_state    傳送器 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_adaptor_closure 協程工具 as_awaitable with_awaitable_senders

核心操作 操作狀態 connect connect_result_t start 完成 set_value set_error set_stopped 變換 transform_env transform_sender apply_sender 傳送器演算法 傳送器工廠 just just_error just_stopped read_env schedule schedule_result_t 傳送器介面卡 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 傳送器消費者 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 起)
輔助標籤型別
struct scheduler_t {};	(2)	(C++26 起)

概念 scheduler 由作為排程器的型別建模，即與 C++ 執行庫協同工作的輕量級執行資源（如執行緒池）的處理程式。

語義要求

給定型別為 Sch 的排程器和型別為 Env 的執行環境，使得 sender_in<schedule_result_t<Sch>, Env> 被滿足，則 /*sender-in-of*/<schedule_result_t<Sch>, Env> 被建模。

排程器的複製建構函式、解構函式、相等比較或交換成員函式不得丟擲異常。

所有這些成員函式以及排程器型別的 schedule 函式都必須是執行緒安全的。

只有當兩個排程器表示相同的執行資源時，它們才相等。

對於給定的排程器 sch，表示式 get_completion_scheduler<set_value_t>(get_env(schedule(sch))) 與 sch 比較相等。

對於給定的排程器 sch，如果表示式 get_domain(sch) 格式良好，則表示式 get_domain(get_env(schedule(sch))) 也格式良好且具有相同型別。

排程器的解構函式不得阻塞任何連線到從 `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)

準備一個任務圖，以便在給定的排程器上執行 (自定義點物件)