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

来自cppreference.com
 
C++
 
并发支持库
线程
(C++11)
(C++20)
(C++20)
(C++20)
(C++20)
(C++17)(C++17)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
(C++11)
互斥
(C++11)
(C++11)  
(C++17)
通用锁管理
(C++11)
(C++11)
(C++17)
(C++11)
(C++14)
(C++11)
(C++11)
(C++11)
(C++11)(C++11)(C++11)(C++11)(C++11)(C++11)
条件变量
(C++11)
(C++11)
(C++11)
(C++11)
信号量
(C++20)(C++20)
闩与屏障
(C++20)
(C++20)
未来体
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
(C++11)
安全回收
(C++26)
(C++26)
(C++26)  
(C++26)
(C++26)
(C++26)
风险指针
(C++26)
(C++26)
(C++26)





原子类型
(C++11)
(C++20)
(C++11)
原子类型的初始化
(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++11)
(C++11)(C++11)(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++11)(C++11)
(C++26)(C++26)
(C++26)(C++26)
(C++11)
(C++20)(C++20)
(C++20)
(C++20)
原子标志的自由函数
(C++11)(C++11)
(C++11)(C++11)
(C++20)(C++20)
(C++20)(C++20)
(C++20)
(C++20)
 
std::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 <memory>
#include <thread>
#include <utility>
 
struct ProgramState
{
    std::packaged_task<void()> task;
    std::future<void> future;
    std::thread worker;
};
 
static void worker(std::shared_ptr<ProgramState> state)
{
    state->task.make_ready_at_thread_exit(); // 立即执行任务
 
    auto status = state->future.wait_for(std::chrono::seconds(0));
    if (status == std::future_status::timeout)
        std::cout << "worker：未来体尚未就绪\n";
    else
        std::cout << "worker：未来体已经就绪\n";
 
    std::cout << "worker：退出\n";
}
 
static std::shared_ptr<ProgramState> create_state()
{
    auto state = std::make_shared<ProgramState>();
    state->task = std::packaged_task<void()>{[]
    {
        std::cout << "task: 已执行\n";
    }};
    state->future = state->task.get_future();
    state->worker = std::thread{worker, state};
    return state;
}
 
int main()
{
    auto state = create_state();
 
    state->worker.join();
    std::cout << "main: worker 完成\n";
 
    auto status = state->future.wait_for(std::chrono::seconds(0));
    if (status == std::future_status::timeout)
        std::cout << "main：未来体尚未就绪\n";
    else
        std::cout << "main：未来体已经就绪";
}

输出： 

task: 已执行
worker：未来体尚未就绪
worker：退出
main: worker 完成
worker：结果尚未就绪
main：未来体已经就绪

参阅

 执行函数
(公开成员函数)
来自“https://zh.cppreference.com/mwiki/index.php?title=cpp/thread/packaged_task/make_ready_at_thread_exit&oldid=93513”