std::shared_future
Определено в заголовке <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.
Члены
| создает объект future (публичный член-функция) |
|
| уничтожает объект future (публичный член-функция) |
|
| присваивает содержимое (публичный член-функция) |
|
Получение результата |
|
| возвращает результат (публичный член-функция) |
|
Состояние |
|
| проверяет, имеет ли 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) | ожидает значения, которое устанавливается асинхронно (шаблон класса) |
© cppreference.com
Licensed under the Creative Commons Attribution-ShareAlike Unported License v3.0.
https://en.cppreference.com/w/cpp/thread/shared_future
