std::shared_future
来自cppreference.com
<tbody>
</tbody>
| 在标头 <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() 的信号
return std::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() 的信号
return std::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) |
等待被异步设置的值 (类模板) |