std:: future

Шаблон класса std::future предоставляет механизм для доступа к результату асинхронных операций:

• Асинхронная операция (созданная через std::async , std::packaged_task или std::promise ) может предоставить объект std::future создателю этой асинхронной операции.

• Создатель асинхронной операции может затем использовать различные методы для запроса, ожидания или извлечения значения из std::future . Эти методы могут блокироваться, если асинхронная операция еще не предоставила значение.

• Когда асинхронная операция готова отправить результат создателю, она может сделать это, модифицируя shared state (например, std::promise::set_value ), который связан с std::future создателя.

Обратите внимание, что std::future ссылается на общее состояние, которое не разделяется с другими асинхронными возвращаемыми объектами (в отличие от std::shared_future ).

Функции-члены

Примеры

#include <future>
#include <iostream>
#include <thread>
int main()
{
    // future из packaged_task
    std::packaged_task<int()> task([]{ return 7; }); // обернуть функцию
    std::future<int> f1 = task.get_future(); // получить future
    std::thread t(std::move(task)); // запустить в потоке
    // future из async()
    std::future<int> f2 = std::async(std::launch::async, []{ return 8; });
    // future из 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 << "Ожидание..." << std::flush;
    f1.wait();
    f2.wait();
    f3.wait();
    std::cout << "Готово!\nРезультаты: "
              << f1.get() << ' ' << f2.get() << ' ' << f3.get() << '\n';
    t.join();
}

Ожидание...Готово!
Результаты: 7 8 9

Пример с исключениями

#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 that may throw
            throw std::runtime_error("Example");
        }
        catch (...)
        {
            try
            {
                // store anything thrown in the promise
                p.set_exception(std::current_exception());
            }
            catch (...) {} // set_exception() may throw too
        }
    });
    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

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