std::execution::scheduler

 

C++

编译器支持

独立和宿主式

语言

标准库

标准库头文件

具名要求

特性测试宏 (C++20)

语言支持库

概念库 (C++20)

诊断库

内存管理库

元编程库 (C++11)

通用工具库

容器库

迭代器库

范围库 (C++20)

算法库

字符串库

文本处理库

数值库

日期和时间库

输入/输出库

文件系统库 (C++17)

并发支持库 (C++11)

执行控制库 (C++26)

技术规范

符号索引

外部库

 

执行控制库

执行概念 调度器 接收器 receiver_of 操作状态    发送器 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_result_t 开始 完成 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 > 概念 scheduler =     std::derived_from<         typename std::remove_cvref_t<Sch>::scheduler_concept,         scheduler_t> &&     /*可查询的*/<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)

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