std::execution::scheduler

 

C++

Compiler-Unterstützung

Freestanding und gehostet

Sprache

Standardbibliothek

Header der Standardbibliothek

Benannte Anforderungen

Feature-Test-Makros (C++20)

Bibliothek für Sprachunterstützung

Konzepte-Bibliothek (C++20)

Diagnostik-Bibliothek

Speicherverwaltungsbibliothek

Metaprogrammierungsbibliothek (C++11)

Allgemeine Dienstprogramme-Bibliothek

Container-Bibliothek

Iterator-Bibliothek

Ranges-Bibliothek (C++20)

Algorithmen-Bibliothek

Bibliothek für Zeichenketten

Textverarbeitungsbibliothek

Numerik-Bibliothek

Datums- und Zeitbibliothek

Ein-/Ausgabe-Bibliothek

Dateisystembibliothek (C++17)

Unterstützung für nebenläufige Programmierung (C++11)

Ausführungssteuerungsbibliothek (C++26)

Technische Spezifikationen

Symbolverzeichnis

Externe Bibliotheken

 

Bibliothek für Ausführungssteuerung

Konzepte der Ausführung scheduler receiver receiver_of operation_state    sender sender_in sender_to Komponenten der Ausführung Ausführungskontexte run_loop Ausführungsdomänen default_domain Forward-Progress-Garantie forward_progress_guarantee Umgebungen empty_env    get_env    env_of_t Abfragen 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 Abschluss-Signaturen 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-Closures sender_adaptor_closure Coroutine-Hilfsmittel as_awaitable with_awaitable_senders

Kernoperationen Operationszustand connect connect_result_t start Abschluss set_value set_error set_stopped Transformation transform_env transform_sender apply_sender Sender-Algorithmen Sender-Fabriken just just_error just_stopped read_env schedule schedule_result_t Sender-Adaptoren 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 Sender-Konsumenten this_thread::sync_wait this_thread::sync_wait_with_variant

 

Definiert in Header <execution>
template< class Sch > concept scheduler =     std::derived_from<         typename std::remove_cvref_t<Sch>::scheduler_concept,        scheduler_t> &&     /*queryable*/<Sch> &&     requires(Sch&& sch)     {         {            std::execution::schedule(std::forward<Sch>(sch))         } -> std::execution::sender;         {             auto(                std::execution::get_completion_scheduler<                    std::execution::set_value_t>(                        std::execution::get_env(                            std::execution::schedule(                                 std::forward<Sch>(sch))))         } -> std::same_as<std::remove_cvref_t<Sch>>;     } &&     std::equality_comparable<std::remove_cvref_t<Sch>> &&     std::copy_constructible<std::remove_cvref_t<Sch>>; };	(1)	(seit C++26)
Hilfstyp für Tags
struct scheduler_t {};	(2)	(seit C++26)

Das Konzept scheduler wird von Typen modelliert, die Scheduler sind, d.h. leichtgewichtige Handler für Ausführungsressourcen wie Thread-Pools, die mit der C++-Ausführungsbibliothek arbeiten.

Semantische Anforderungen

Gegeben sei ein Scheduler vom Typ Sch und eine Ausführungsumgebung vom Typ Env, sodass sender_in<schedule_result_t<Sch>, Env> erfüllt ist, dann wird /*sender-in-of*/<schedule_result_t<Sch>, Env> modelliert.

Die Copy-Konstruktor-, Destruktor-, Gleichheitsvergleichs- oder Swap-Memberfunktionen des Schedulers dürfen nicht werfen.

Alle diese Memberfunktionen sowie die schedule-Funktion des Scheduler-Typs müssen Thread-sicher sein.

Zwei Scheduler sind nur dann gleich, wenn sie dieselbe Ausführungsressource darstellen.

Für einen gegebenen Scheduler sch ist der Ausdruck get_completion_scheduler<set_value_t>(get_env(schedule(sch))) gleich sch.

Für einen gegebenen Scheduler sch, wenn der Ausdruck get_domain(sch) wohlgeformt ist, dann ist der Ausdruck get_domain(get_env(schedule(sch))) ebenfalls wohlgeformt und hat denselben Typ.

Der Destruktor eines Schedulers darf die ausstehende Fertigstellung von Empfängern, die mit den von schedule zurückgegebenen Senderobjekten verbunden sind, nicht blockieren (die zugrunde liegende Ressource kann eine separate API bereitstellen, um auf die Fertigstellung übermittelter Funktions-Objekte zu warten).

Beispiele

einfache Wrapper-Klasse für std::execution::run_loop, die ständig die run_loop-Warteschlange auf einem einzigen dedizierten Thread abfragt. Demo mit einer Entwurfsreferenzimplementierung: https://godbolt.org/z/146fY4Y91

Führen Sie diesen Code aus

#include <execution>
#include <iostream>
#include <thread>
 
class single_thread_context
{
    std::execution::run_loop loop_{};
    std::jthread thread_;
 
public:
    single_thread_context()
        : thread_([this] { loop_.run(); })
    {}
    single_thread_context(single_thread_context&&) = delete;
 
    ~single_thread_context()
    {
        loop_.finish();
    }
 
    std::execution::scheduler auto get_scheduler() noexcept
    {
        return loop_.get_scheduler();
    }
};
 
int main()
{
    single_thread_context ctx;
 
    std::execution::sender auto snd =
        std::execution::schedule(ctx.get_scheduler())
        | std::execution::then([]
            {
                std::cout << "Hello world! Have an int.\n";
                return 015;
            })
        | std::execution::then([](int arg) { return arg + 42; });
 
    auto [i] = std::this_thread::sync_wait(snd).value();
 
    std::cout << "Back in the main thread, result is " << i << '\n';
}

Ausgabe

Hello world! Have an int.
Back in the main thread, result is 55

Siehe auch

execution::schedule (C++26)

bereitet einen Task-Graphen für die Ausführung auf einem gegebenen Scheduler vor (customization point object)