std:: future

Die Klassenvorlage std::future bietet einen Mechanismus, um auf das Ergebnis asynchroner Operationen zuzugreifen:

• Ein asynchroner Vorgang (erstellt via std::async , std::packaged_task oder std::promise ) kann dem Ersteller dieses asynchronen Vorgangs ein std::future -Objekt bereitstellen.

• Der Ersteller des asynchronen Vorgangs kann dann verschiedene Methoden verwenden, um einen Wert aus dem std::future abzufragen, darauf zu warten oder ihn zu extrahieren. Diese Methoden können blockieren, wenn der asynchrone Vorgang noch keinen Wert bereitgestellt hat.

• Wenn der asynchrone Vorgang bereit ist, ein Ergebnis an den Ersteller zu senden, kann er dies durch Modifizieren des shared state tun (z.B. std::promise::set_value ), der mit dem std::future des Erstellers verknüpft ist.

Beachten Sie, dass std::future auf einen gemeinsamen Zustand verweist, der nicht mit anderen asynchronen Rückgabeobjekten geteilt wird (im Gegensatz zu std::shared_future ).

Memberfunktionen

Beispiele

#include <future>
#include <iostream>
#include <thread>
int main()
{
    // future von einem packaged_task
    std::packaged_task<int()> task([]{ return 7; }); // Funktion kapseln
    std::future<int> f1 = task.get_future(); // Future erhalten
    std::thread t(std::move(task)); // in einem Thread starten
    // future von async()
    std::future<int> f2 = std::async(std::launch::async, []{ return 8; });
    // future von einem promise
    std::promise<int> p;
    std::future<int> f3 = p.get_future();
    std::thread([&p]{ p.set_value_at_thread_exit(9); }).detach();
    std::cout << "Waiting..." << std::flush;
    f1.wait();
    f2.wait();
    f3.wait();
    std::cout << "Done!\nResults are: "
              << f1.get() << ' ' << f2.get() << ' ' << f3.get() << '\n';
    t.join();
}

Waiting...Done!
Results are: 7 8 9

Beispiel mit Ausnahmen

#include <future>
#include <iostream>
#include <thread>
int main()
{
    std::promise<int> p;
    std::future<int> f = p.get_future();
    std::thread t([&p]
    {
        try
        {
            // Code, der eine Exception werfen könnte
            throw std::runtime_error("Example");
        }
        catch (...)
        {
            try
            {
                // Alle geworfenen Exceptions im Promise speichern
                p.set_exception(std::current_exception());
            }
            catch (...) {} // set_exception() könnte ebenfalls werfen
        }
    });
    try
    {
        std::cout << f.get();
    }
    catch (const std::exception& e)
    {
        std::cout << "Exception from the thread: " << e.what() << '\n';
    }
    t.join();
}

Exception from the thread: Example

Siehe auch