std::packaged_task<R(Args...)>::make_ready_at_thread_exit
void make_ready_at_thread_exit( ArgTypes... args ); | (с C++11) |
Вызывает сохранённую задачу, как если бы INVOKE<R>(f, args...), где f — сохранённая задача. Значение возврата задачи или любое исключение, брошенное ею, сохраняется в общем состоянии *this.
Общее состояние становится готовым только после завершения текущей нити и уничтожения всех объектов со сроком жизни, локальной для нити.
Параметры
| args | - | параметры для передачи при вызове сохранённой задачи |
Значение возврата
(нет)
Исключения
std::future_error при следующих условиях ошибки:
- Сохранённая задача уже была вызвана. Категория ошибки устанавливается в
promise_already_satisfied. - У
*thisнет общего состояния. Категория ошибки устанавливается вno_state.
Пример
#include <chrono>
#include <functional>
#include <future>
#include <iostream>
#include <thread>
#include <utility>
void worker(std::future<void>& output)
{
std::packaged_task<void(bool&)> my_task{[](bool& done) { done = true; }};
auto result = my_task.get_future();
bool done = false;
my_task.make_ready_at_thread_exit(done); // execute task right away
std::cout << "worker: done = " << std::boolalpha << done << std::endl;
auto status = result.wait_for(std::chrono::seconds(0));
if (status == std::future_status::timeout)
std::cout << "worker: result is not ready yet" << std::endl;
output = std::move(result);
}
int main()
{
std::future<void> result;
std::thread{worker, std::ref(result)}.join();
auto status = result.wait_for(std::chrono::seconds(0));
if (status == std::future_status::ready)
std::cout << "main: result is ready" << std::endl;
}Вывод:
worker: done = true worker: result is not ready yet main: result is ready
См. также
| выполняет функцию (публичный член-функция) |
© cppreference.com
Licensed under the Creative Commons Attribution-ShareAlike Unported License v3.0.
https://en.cppreference.com/w/cpp/thread/packaged_task/make_ready_at_thread_exit