std::execution::bulk, std::execution::bulk_chunked, std::execution::bulk_unchunked

 

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>
std::execution::sender auto bulk( std::execution::sender auto input,            std::integral auto size,            auto&& policy,            std::invocable<decltype(size),                           /*values-sent-by*/(input)...> function );	(1)	(自 C++26 起)
std::execution::sender auto bulk_chunked( std::execution::sender auto input,                    std::integral auto size,                    auto&& policy,                    std::invocable<decltype(size), decltype(size),                                   /*values-sent-by*/(input)...> function2 );	(2)	(自 C++26 起)
std::execution::sender auto bulk_unchunked( std::execution::sender auto input,                      std::integral auto size,                      std::invocable<decltype(size), decltype(size),                                     /*values-sent-by*/(input)...> function );	(3)	(自 C++26 起)

参数

input	-	发送器，一旦执行，会发送函数执行所依据的值
policy	-	附加到 function/function2 的执行策略
function	-	可调用对象，将为范围 [​0​, size) 中的每个索引调用，同时也会传递输入发送器生成的值
function2	-	与 function 相同，但使用索引对 (b, e) 调用，其中 b < e，因此，对于范围 [[0, size) 中的每个索引 i，都恰好调用一次 function2，使得 b <= i < e。

返回值

返回一个发送器，描述由输入发送器描述的任务图，并添加一个节点，该节点使用范围 [​0​, size) 中的索引调用提供的函数，同时也将输入发送器发送的值作为参数传递。

function/function2 保证在返回的发送器启动之前不会开始执行。

错误完成

所有由 input 传入的错误都会被转发。

此外，允许发送器以包含 std::exception_ptr 错误的错误完成：

• 由 function 抛出的任何异常
• 如果实现无法分配所需资源，则为 std::bad_alloc
• 对于其他内部错误（例如，无法将异常从执行上下文传播到调用者）的从 std::runtime_error 派生的异常。

取消

未定制的 std::execution::bulk、std::execution::bulk_chunk 和 std::execution::bulk_unchunked 会转发来自 input 的停止完成信号。它们不提供产生停止完成信号的额外机制。

注解

当调用 std::execution::bulk 和 std::execution::bulk_chunked 时，function/function2 的不同调用可能发生在同一执行代理上。

当调用 std::execution::bulk_unchunked 时，function 的不同调用必须发生在不同的执行代理上。

std::execution::bulk 的默认实现基于 std::execution::bulk_chunked。虽然可以自定义 std::execution::bulk，但预计大多数情况下只会自定义 std::execution::bulk_chunked。

在没有自定义 std::execution::bulk 和 std::execution::bulk_chunked 的情况下，std::execution::bulk 和 std::execution::bulk_chunk 的行为是串行执行 function，这并不是特别有用。 期望实现具有自定义项，这将使在不同调度器上运行 std::execution::bulk 和 std::execution::bulk_chunked 更有用。

std::execution::bulk_unchunked 旨在用于 function 的不同调用之间可能存在依赖关系，并且需要并发前向进度保证（并行前向进度是不够的）的情况。 使用大小为 1000 运行 std::execution::bulk_unchunked 将需要 1000 个执行代理（例如，线程）同时运行。

std::execution::bulk_unchunked 不需要执行策略，因为已经预期 function 能够并发运行。

示例

execution::bulk 的可能用法。

std::vector<double> x;
std::vector<double> y;
//...
sender auto process_elements
    = just(get_coefficient())
    | bulk(x.size(), [&](size_t i, double a)
    {
        y[i] = a * x[i] + y[i];
    });
// process_elements describes the work described by calling a function to
// get a coefficient `a`, and using it to execute
//   y[i] = a * x[i] + y[i]
// for each `i` in range [0, x.size())

execution::bulk_chunked 的可能用法。

std::vector<std::uint32_t> data = ...;
std::atomic<std::uint32_t> sum{0};
sender auto s = bulk_chunked(just(), par, 100000,
    [&sum, &data](int begin, int end)
    {
        auto partial_sum = std::accumulate(data.begin() + begin, data.begin() + end, 0U);
        sum.fetch_add(partial_sum);
    });
// the atomic object will not be touched 100000 times; will execute faster than bulk()