Как одновременно ждать несколько динамических чисел ожидаемых функций ⇐ C++

[Anonymous]

Я использую Boost 1.84.0.
Boost Asio имеет несколько параллельных функций co_wait.
Я понял, что количество ожидающих элементов иногда статично, но иногда определяется динамически.

• Пример статического номера, async_read и тайм-аут (2).
• Пример динамического номера, async_write все подключенные клиенты чата и все они завершены затем возвращает сообщение типа «сообщение доставлено».

Ожидание статического (фиксированного) количества асинхронных функций
Похоже, что для выбора версии параметра Ops с вариацией требуется, чтобы количество асинхронных операций определялось во время компиляции. Здесь можно использовать статическое количество нескольких ожиданий, которые используют deferred и/или экспериментальный::use_promise. Его нельзя использовать с use_awaitable и/или пользовательской функцией awaitable func().
https://www.boost.org/doc/ libs/1_84_0/doc/html/boost_asio/reference/experimental__make_parallel_group/overload2.html
experimental::awaitable_operator может использоваться статическое число нескольких ожиданий, которые используют use_awaitable и/ или определяемую пользователем функцию awaitable func(). Его нельзя использовать с deferred

Код: Выделить всё

and/or

experimental::use_promise`.
https://www.boost.org/doc/libs/1_84_0/d ... tines.html #boost_asio.overview.composition.cpp20_coroutines.co_ordinating_parallel_coroutines
Ожидание динамического количества асинхронных функций
Для динамического количества асинхронных функций мы можем использовать версию диапазона экспериментальной::make_parallel_group.
https://www.boost.org/doc/libs/1_84_0/d ... load2.html
Вот пример кода:

Код: Выделить всё

#include 
#include 
#include 
#include 
#include 
#include 
#include 
namespace as = boost::asio;

as::awaitable test() {
auto exe = co_await as::this_coro::executor;
using op_type = decltype(as::post(exe, as::append(as::deferred, int{})));
std::vector ops;
for (int i = 0; i != 5; ++i) {
ops.push_back(as::post(exe, as::append(as::deferred, i*10)));
}
auto [orders, values] =
co_await as::experimental::make_parallel_group(
ops
).async_wait(
as::experimental::wait_for_all(),
as::deferred
);
for (auto order : orders) {
std::cout 

Подробнее здесь: [url]https://stackoverflow.com/questions/78254292/how-to-wait-multiple-dynamic-number-of-awaitable-functions-parallely[/url]