std::shared_future
来自 cppreference.com
| 在头文件 <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(); // waits for the signal from 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(); // waits for the signal from 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); // wait for the threads to become ready fut1.wait(); fut2.wait(); // the threads are ready, start the clock start = std::chrono::high_resolution_clock::now(); // signal the threads to go ready_promise.set_value(); std::cout << "Thread 1 received the signal " << result1.get().count() << " ms after start\n" << "Thread 2 received the signal " << result2.get().count() << " ms after start\n"; }
可能的输出
Thread 1 received the signal 0.072 ms after start Thread 2 received the signal 0.041 ms after start
[编辑] 另请参阅
| (C++11) |
异步运行函数（可能在新线程中）并返回一个将保存结果的 std::future (函数模板) |
| (C++11) |
等待异步设置的值 (类模板) |
