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/cpp/thread/shared_future
