Execution control library (since C++26)

Библиотека управления выполнением предоставляет фреймворк для управления асинхронным выполнением на общих ресурсах выполнения.

Библиотека стремится предоставить словарные типы для асинхронных операций и позволить построение графов выполнения задач простым, композируемым способом.

Общебиблиотечные определения

• Отправитель : Описание асинхронной работы, отправляемой на выполнение. Создает состояние операции (ниже).

• Отправители асинхронно "отправляют" свои результаты слушателям, называемым "получателями" (ниже).
• Отправители могут быть скомпонованы в графы задач с использованием обобщённых алгоритмов.
• Фабрики и адаптеры отправителей - это обобщённые алгоритмы, которые инкапсулируют распространённые асинхронные паттерны в объектах, удовлетворяющих концепции sender .

• Receiver : Обобщенный callback, который потребляет или "принимает" асинхронные результаты, производимые sender'ом.

• Получатели имеют три различных «канала», через которые отправитель может передавать результаты: успех, сбой и отмена, называемые «значение», «ошибка» и «остановка».
• Получатели предоставляют расширяемую среду выполнения: набор пар ключ/значение, которые потребитель может использовать для параметризации асинхронной операции.

• Состояние операции : Объект, содержащий состояние, необходимое для асинхронной операции.

• Отправитель и получатель соединяются при передаче в функцию std::execution::connect .
• Результатом соединения отправителя и получателя является состояние операции.
• Работа не ставится в очередь на выполнение до тех пор, пока не будет вызван метод " start " для состояния операции.
• После запуска время жизни состояния операции не может завершиться до окончания асинхронной операции, и его адрес должен оставаться стабильным.

• Scheduler : Легковесный дескриптор контекста выполнения.

• Контекст выполнения - это источник асинхронного выполнения, такой как пул потоков или поток GPU.
• Планировщик - это фабрика для отправителя, который завершает своего получателя из потока выполнения, принадлежащего контексту выполнения.

Утилиты библиотеки

Концепции

Планировщики

Отправители

Приёмники

Состояния операций

Утилитарные компоненты

Контексты выполнения

Домены выполнения

Гарантия прогресса выполнения

Окружения

Запросы

Сигнатуры завершения

Утилиты для корутин

Основные операции

Состояние операции

Функции завершения

Эти функции вызываются отправителями для уведомления получателей о завершении работы.

Алгоритмы отправителя

Фабрики отправителей

Фабрика отправителя — это функция, возвращающая отправитель, параметры которой имеют типы, для которых концепция sender является false .

Ниже приведены фабрики отправителей:

Конвейерные адаптеры отправителей

Адаптеры отправителей

Адаптер отправителя — это функция, возвращающая отправитель, параметры которой включают по крайней мере один, чей тип удовлетворяет концепции sender , и для которой возвращаемый отправитель является родительским отправителем для аргументов-отправителей функции-адаптера.

Ниже представлены адаптеры отправителя:

Потребители отправителей

Отправитель-потребитель — это алгоритм, который принимает один или несколько отправителей в качестве параметров и не возвращает отправитель.

Пример

#include <cstdio>
#include <execution>
#include <string>
#include <thread>
#include <utility>
using namespace std::literals;
int main()
{
    std::execution::run_loop loop;
    std::jthread worker([&](std::stop_token st)
    {
        std::stop_callback cb{st, [&]{ loop.finish(); }};
        loop.run();
    });
    std::execution::sender auto hello = std::execution::just("hello world"s);
    std::execution::sender auto print
        = std::move(hello)
        | std::execution::then([](std::string msg)
        {
            return std::puts(msg.c_str());
        });
    std::execution::scheduler auto io_thread = loop.get_scheduler();
    std::execution::sender auto work = std::execution::on(io_thread, std::move(print));
    auto [result] = std::this_thread::sync_wait(std::move(work)).value();
    return result;
}

hello world

Смотрите также