std::future
Материал из cppreference.com
<tbody>
</tbody>
| Определено в заголовочном файле <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) |
ожидает значение (возможно, на которое ссылаются другие разделяемые состояния), которое устанавливается асинхронно (шаблон класса) |
