std::packaged_task<R(Args...)>::make_ready_at_thread_exit
来自cppreference.com
< cpp | thread | packaged task
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); // 立即执行任务 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:结果尚未准备好" << 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:结果已经准备好" << std::endl; }
输出:
worker:done = true worker:结果尚未准备好 main:结果已经准备好
参阅
执行函数 (公开成员函数) |