Execution control library (since C++26)

실행 제어 라이브러리는 일반적인 실행 리소스에서 비동기 실행을 관리하기 위한 프레임워크를 제공합니다.

이 라이브러리는 비동기 연산을 위한 어휘 타입을 제공하고, 간단하고 구성 가능한 방식으로 태스크 실행 그래프를 구축할 수 있도록 하는 것을 목표로 합니다.

라이브러리 전체 정의

• Sender : 실행을 위해 전송될 비동기 작업에 대한 설명입니다. (아래의) 연산 상태를 생성합니다.

• 송신자(senders)는 비동기적으로 자신의 결과를 "수신자(receivers)"라고 불리는 리스너에게 "전송(send)"합니다.
• 송신자(senders)는 제네릭 알고리즘을 사용하여 태스크 그래프(task graphs) 로 구성될 수 있습니다.
• 송신자 팩토리 및 어댑터(sender factories and adaptors) 는 sender 개념을 만족하는 객체에서 일반적인 비동기 패턴을 캡슐화하는 제네릭 알고리즘입니다.

• Receiver : 비동기 작업 결과를 생성하는 sender가 생산한 결과를 소비하거나 "수신"하는 일반화된 콜백입니다.

• 수신자는 발신자가 결과를 전파할 수 있는 세 가지 다른 "채널"을 가집니다: 성공, 실패, 취소됨, 각각 "값", "오류", "중단됨"으로 명명됩니다.
• 수신자는 확장 가능한 실행 환경을 제공합니다: 소비자가 비동기 작업을 매개변수화하는 데 사용할 수 있는 키/값 쌍의 집합입니다.

• Operation State : 비동기 작업에 필요한 상태를 포함하는 객체입니다.

• 송신자(sender)와 수신자(receiver)는 std::execution::connect 함수에 전달될 때 연결됩니다.
• 송신자와 수신자를 연결한 결과는 연산 상태(operation state)입니다.
• 연산 상태에서 " start "가 호출되기 전까지는 실행을 위해 작업이 큐에 들어가지 않습니다.
• 시작된 후에는 비동기 연산이 완료되기 전에 연산 상태의 수명이 종료될 수 없으며, 그 주소는 안정적이어야 합니다.

• Scheduler : 실행 컨텍스트에 대한 경량 핸들입니다.

• 실행 컨텍스트는 스레드 풀이나 GPU 스트림과 같은 비동기 실행의 소스입니다.
• 스케줄러는 실행 컨텍스트가 소유한 실행 스레드에서 해당 리시버를 완료하는 sender의 팩토리입니다.

라이브러리 유틸리티

개념

스케줄러

발신자

수신기

동작 상태

유틸리티 컴포넌트

실행 컨텍스트

실행 도메인

진행 보장

환경

쿼리

완료 시그니처

코루틴 유틸리티

핵심 연산

동작 상태

완성 함수

이러한 함수들은 송신자가 수신자에게 작업 완료를 알리기 위해 호출됩니다.

송신자 알고리즘

Sender 팩토리

발신자 팩토리는 발신자를 반환하는 함수이며, 그 매개변수들의 타입에 대해 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

참고 항목