std::execution::scheduler

 

C++

编译器支持

自立实现与有宿主实现

语言

标准库

标准库标头

具名要求

功能特性测试宏(C++20)

语言支持库

概念库(C++20)

诊断库

内存管理库

元编程库(C++11)

通用工具库

容器库

迭代器库

范围库(C++20)

算法库

字符串库

文本处理库

数值库

日期和时间库

输入/输出库

文件系统库(C++17)

并发支持库(C++11)

执行控制库(C++26)

技术规范

符号索引

外部库

 

执行控制库

执行概念 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_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<         typenamestd::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> 得以实现。

调度器的复制构造函数、析构函数、相等性比较或者 swap 成员函数都必须不抛出异常。

所有这些成员函数，以及该调度器类型的 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::schedulerauto get_scheduler()noexcept{return loop_.get_scheduler();}};   int main(){ single_thread_context ctx;   std::execution::senderauto snd = std::execution::schedule(ctx.get_scheduler())| std::execution::then([]{std::cout<<"Hello world! Have an int.\n";return015;})| std::execution::then([](int arg){return arg +42;});   auto[i]= std::this_thread::sync_wait(snd).value();   std::cout<<"回到主线程，结果为 "<< i <<'\n';}

输出：

Hello world! Have an int. 回到主线程，结果为 55

参阅

execution::schedule (C++26)

准备一个要在给定调度器上执行的任务图 (定制点对象)