Давайте предположим, что у меня есть коратика, бегущая по пряди. Я хотел бы, чтобы завершение было опубликовано родительскому исполнителю Strand (т. Е. a thread_pool ), также выпуская прядь. Как лучше всего достичь этого результата без чрезмерной накладной расходы? Мне кажется, что F2 несет накладные расходы и нарушает местность рассуждений для кода. Но F3 не может сделать то, что я хочу в конкретном случае, когда граничный исполнитель является родителем Strand. Привязывание F3 с любым другим неродственным исполнителем было бы в порядке, но не родитель Strand.
boost::asio::awaitable f2(auto& pool, auto& strand)
{
assert(strand.running_in_this_thread());
co_await boost::asio::post(bind_executor(pool, boost::asio::deferred));
}
boost::asio::awaitable f3([[maybe_unused]] auto& pool, auto& strand)
{
assert(strand.running_in_this_thread());
co_return;
}
int main(int argc, char* argv[])
{
boost::asio::thread_pool pool{std::thread::hardware_concurrency()};
auto strand = boost::asio::make_strand(pool);
co_spawn(strand, f2(pool, strand), bind_executor(pool, [&](std::exception_ptr exception) {
assert(!strand.running_in_this_thread()); // Succeeds, but required an explicit `post` at the end of `f2`
}));
co_spawn(strand, f3(pool, strand), bind_executor(pool, [&](std::exception_ptr exception) {
assert(strand.running_in_this_thread()); // actual result : succeeds
assert(!strand.running_in_this_thread()); // expected result, but currently fails
}));
pool.join();
}
< /code>
edit < /h1>
@sehe Я упускаю точку зрения, я думаю. Завершение, передаваемое Co_spawn , всегда связано с прямой, но никогда не с родительским исполнителем Strand (пул).
Я постараюсь выразить свою проблему по -другому. Я могу упростить пример кода, полностью удалив Coroutines. Отправка в Pool из Strand выполняет встроенные, потому что оба истины, что мы уже находимся внутри Strand и Inside Pool . Если я хочу освободить Strand, я могу прекратить использование Dispatch и использовать post или defer .
Теперь вернемся к Coroutines, мое текущее понимание состоит в том, что продолжение ожидаемого будет отправлено соответствующему исполнителю. Это означает, что он выполнит встроенный, если мой связанный исполнитель является родителем Strand , потому что я уже работаю внутри. После этого завершение Coroutine отправляется в тот же пул и никогда не возвращается в Strand . Но мне кажется, что есть неоправданные накладные расходы в наличии как post , так и для отправки для того же продолжения.int main()
{
boost::asio::thread_pool pool{1};
auto strand = boost::asio::make_strand(pool);
// Similar to my initial `f3`
boost::asio::dispatch(bind_executor(strand, [&]() {
boost::asio::dispatch(bind_executor(pool, [&]() {
assert(strand.running_in_this_thread());
}));
}));
// Similar to my initial `f2`
boost::asio::dispatch(bind_executor(strand, [&]() {
boost::asio::post(bind_executor(pool, [&]() {
boost::asio::dispatch(bind_executor(pool, [&]() {
assert(!strand.running_in_this_thread());
}));
}));
}));
// What I'm hoping for is the following
boost::asio::dispatch(bind_executor(strand, [&]() {
boost::asio::post(bind_executor(pool, [&]() {
assert(!strand.running_in_this_thread());
}));
}));
pool.join();
}
Подробнее здесь: https://stackoverflow.com/questions/795 ... e-a-strand
