std::shared_future

来自cppreference.com
< cpp‎ | thread
 
 
并发支持库
线程
(C++11)
(C++20)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
协作式取消
互斥
通用锁管理
(C++11)
(C++11)
(C++11)
(C++11)
条件变量
(C++11)
信号量
闩与屏障
(C++20)
(C++20)
未来体
(C++11)
(C++11)
shared_future
(C++11)
(C++11)
安全回收
风险指针
原子类型
(C++11)
(C++20)
原子类型的初始化
(C++11)(C++20 弃用)
(C++11)(C++20 弃用)
内存定序
(C++11)(C++26 弃用)
原子操作的自由函数
原子标志的自由函数
 
 
在标头 <future> 定义
template<class T >class shared_future;
(1) (C++11 起)
template<class T >class shared_future<T&>;
(2) (C++11 起)
template<>class shared_future<void>;
(3) (C++11 起)

类模板 std::shared_future 提供一种访问异步操作结果的机制,类似 std::future,但允许多个线程等候同一共享状态。不同于仅可移动的 std::future(只有一个实例能指代任何特定的异步结果),std::shared_future 可复制而且多个共享未来体对象能指代同一共享状态。

从多个线程访问同一共享状态,若每个线程都是通过其自身的 shared_future 对象副本进行访问,则是安全的。

目录

[编辑]成员函数

构造未来体对象
(公开成员函数)[编辑]
销毁未来体对象
(公开成员函数)
赋值内容
(公开成员函数)
获取结果
返回结果
(公开成员函数)[编辑]
状态
检查未来体是否拥有共享状态
(公开成员函数)[编辑]
等待结果变得可用
(公开成员函数)[编辑]
等待结果,如果在指定的超时间隔后仍然无法得到结果,则返回。
(公开成员函数)[编辑]
等待结果,如果在已经到达指定的时间点时仍然无法得到结果,则返回。
(公开成员函数)[编辑]

[编辑]示例

shared_future 可用于同时向多个线程发信,类似 std::condition_variable::notify_all()

#include <chrono>#include <future>#include <iostream>   int main(){std::promise<void> ready_promise, t1_ready_promise, t2_ready_promise; std::shared_future<void> ready_future(ready_promise.get_future());   std::chrono::time_point<std::chrono::high_resolution_clock> start;   auto fun1 =[&, ready_future]()->std::chrono::duration<double, std::milli>{ t1_ready_promise.set_value(); ready_future.wait();// 等待来自 main() 的信号returnstd::chrono::high_resolution_clock::now()- start;};     auto fun2 =[&, ready_future]()->std::chrono::duration<double, std::milli>{ t2_ready_promise.set_value(); ready_future.wait();// 等待来自 main() 的信号returnstd::chrono::high_resolution_clock::now()- start;};   auto fut1 = t1_ready_promise.get_future();auto fut2 = t2_ready_promise.get_future();   auto result1 =std::async(std::launch::async, fun1);auto result2 =std::async(std::launch::async, fun2);   // 等待线程变为就绪 fut1.wait(); fut2.wait();   // 线程已就绪,开始时钟 start =std::chrono::high_resolution_clock::now();   // 向线程发信使之运行 ready_promise.set_value();   std::cout<<"线程 1 启动 "<< result1.get().count()<<" ms 后接到信号\n"<<"线程 2 启动 "<< result2.get().count()<<" ms 后接到信号\n";}

可能的输出:

线程 1 启动 0.072 ms 后接到信号 线程 2 启动 0.041 ms 后接到信号

[编辑]参阅

(C++11)
异步运行一个函数(有可能在新线程中执行),并返回将保有它的结果的 std::future
(函数模板)[编辑]
(C++11)
等待被异步设置的值
(类模板)[编辑]
close