std::packaged_task<R(Args...)>::make_ready_at_thread_exit

来自cppreference.com
 
 
并发支持库
线程
(C++11)
(C++20)
(C++20)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
原子类型
(C++11)
(C++20)
原子类型的初始化
(C++11)(C++20 中弃用)
(C++11)(C++20 中弃用)
原子操作的自由函数
原子标志的自由函数
内存序
互斥
(C++11)
通用锁管理
(C++11)
(C++11)
(C++11)
(C++11)(C++11)(C++11)
(C++11)
(C++11)
条件变量
(C++11)
信号量
闩与屏障
(C++20)
(C++20)
future
(C++11)
(C++11)
(C++11)
(C++11)
 
 
void make_ready_at_thread_exit( ArgTypes... args );
(C++11 起)

如同以 INVOKE<R>(f, args...) 调用存储的任务 f。任务返回值或任何抛出的异常被存储于 *this 的共享状态。

只有在在当前线程退出,并销毁所有线程局域存储期对象后,共享状态才会就绪。

参数

args - 调用时传递给存储任务的参数

返回值

(无)

异常

在以下情况下抛出 std::future_error

示例

#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:结果已经准备好

参阅

执行函数
(公开成员函数)