std::future
Материал из cppreference.com
| Определено в заголовочном файле <future>
|
||
| template< class T > class future; |
(1) | (начиная с C++11) |
| template< class T > class future<T&>; |
(2) | (начиная с C++11) |
| template<> class future<void>; |
(3) | (начиная с C++11) |
Шаблонный класс std::future обеспечивает механизм доступа к результатам асинхронных операций:
- Асинхронные операции (созданные с помощью std::async, std::packaged_task или std::promise) могут вернуть объект типа
std::futureсоздателю этой операции.
- Создатель асинхронной операции может использовать различные методы для запроса, ожидания или получения значения из
std::future. Эти методы могут заблокировать выполнение до получения результата асинхронной операции.
- Когда асинхронная операция готова к отправке результата её создателю, она может сделать это, изменив общее состояние (например, std::promise::set_value), которое связано с
std::futureсоздателя.
Обратите внимание, что std::future ссылается на общее состояние, которое не используется никакими другими асинхронными возвращаемыми объектами (в отличие от std::shared_future).
Содержание |
[править] Функции-элементы
| создаёт объект future (public функция-элемент) | |
| разрушает объект future (public функция-элемент) | |
| перемещает объект future (public функция-элемент) | |
| передаёт общее состояние из *this в shared_future и возвращает его (public функция-элемент) | |
Получение результата | |
| возвращает результат (public функция-элемент) | |
Состояние | |
| проверяет, имеет ли future общее состояние (public функция-элемент) | |
| ждёт, пока результат станет доступным (public функция-элемент) | |
| ждёт результата, возвращается, если он недоступен в течение указанного времени ожидания (public функция-элемент) | |
| ждёт результата, возвращается, если он недоступен, пока не будет достигнут указанный момент времени (public функция-элемент) | |
[править] Пример
Запустить этот код
#include <iostream> #include <future> #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 <thread> #include <iostream> #include <future> int main() { std::promise<int> p; std::future<int> f = p.get_future(); std::thread t([&p]{ try { // код, который может бросить исключение throw std::runtime_error("Пример"); } catch(...) { try { // хранить всё, что брошено в promise p.set_exception(std::current_exception()); } catch(...) {} // set_exception() тоже может бросить исключение } }); try { std::cout << f.get(); } catch(const std::exception& e) { std::cout << "Исключение из потока: " << e.what() << '\n'; } t.join(); }
Вывод:
Исключение из потока: Пример
[править] Смотрите также
| (C++11) |
выполняет функцию асинхронно (возможно, в новом потоке) и возвращает std::future, который будет содержать результат (шаблон функции) |
| (C++11) |
ожидает значение (возможно, на которое ссылаются другие разделяемые состояния), которое устанавливается асинхронно (шаблон класса) |
