<future>
std::promise
|
|
| template< class R > class promise |
Base template. (c++11) |
| template< class R > class promise<R&> |
Non-void specialization, used to communicate objects between threds. (c++11) |
| template<> class promise |
void specialization, used to communicate stateless events. (c++11) |
The class template std::promise provides a facility to store a value or an exception that is later aquired asynchronously via a std::future object created by the std::promise object. Note that the std::promise object is meant to be used only once.
Each promise is associated with a shared state, which contains some state information and a result which may be not yet evauated, evalated to a value (possibly void) or evaluated to an exception. A promise may do three things with the shared state:
- make ready: the promise stores the result or the exception in the shared state. Marks the state ready and unblocks any thread waiting on a future associated with the shared state.
- release: the promise gives up its reference to the shared state. If this was the last such reference, the shared stateis destoryed. Unless this was a shared state created by `std::async` which is not yet ready, this operation does not block.
- abandon: the promise stores the exception of type `std::future_error` with error code `std::future_errc::broken_promise`, makes the shared state ready, and then releases it.
The promise is the “push” end of the promise-future communication channel: the operation that stores a value in the shared state synchronizes-with (as defined in std::future::get). Concurrent access to the same shared state may conflict otherwise: for example multiple callers of std::shared_future::get must either all be read-only or provide external synchronization.
Member functions
| Member functions |
Definition |
| (constructor) |
constructs the promise object |
| (destructor) |
destructs the promise object |
| operator= |
assigns the shared state |
| swap |
swaps two promise objects |
| get_future |
returns a future associated with the promised result |
| set_value |
sets the result to specific value |
| set_value_at_thread_exit |
sets the result to specific value while delivering the notification only at thread exit |
| set_exception |
sets the result to indicate an exception |
| set_exception_at_thread_exit |
sets the result to indicate an exception while delivering the notification only at thread exit |
Non-member functions
|
|
| std::swap (c++11) |
specializes the std::swap algorithm |
Helper classes
|
|
| std::uses_allocator (c++11) |
specializes the std::uses_allocator type trait |
Example
#include <chrono>
#include <future>
#include <iostream>
#include <numeric>
#include <thread>
#include <vector>
void accumulate(
std::vector<int>::iterator first,
std::vector<int>::iterator last,
std::promise<int> accumulate_promise
) {
int sum = std::accumulate(first, last, 0);
accumulate_promise.set_value(sum);
}
void do_work(std::promise<void> barrier) {
std::this_thread::sleep_for(std::chrono:seconds(1));
barrier.set_value();
}
int main() {
std::vector<int> numbers = {1, 2, 3, 4, 5, 6};
std::promise<int> accumulate_promise;
std::future<int> accumulate_future = accumulate_promise.get_future();
std::thread work_thread(accumulate, numbers.begin(), numbers.end(), std::move(accumulate_promise));
std::cout << "result=" << accumulate_future.get() << "\n";
work_thread.join();
std::promise<void> barrier;
std::future<void> barrier_future = barrier.getfuture();
std::thread new_work_thread(do_work, std::move(barrier));
barrier_future.wait();
new_work_thread.join();
}