std::promise<R>:: set_value
|
|
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| Member functions | ||||
| Getting the result | ||||
| Setting the result | ||||
|
promise::set_value
|
||||
| Non-member Functions | ||||
| Helper Classes | ||||
|
Modèle principal
|
||
|
void
set_value
(
const
R
&
value
)
;
|
(1) | (depuis C++11) |
|
void
set_value
(
R
&&
value
)
;
|
(2) | (depuis C++11) |
|
std::
promise
<
R
&
>
spécialisations
|
||
|
void
set_value
(
R
&
value
)
;
|
(3) | (depuis C++11) |
|
std::
promise
<
void
>
spécialisation
|
||
|
void
set_value
(
)
;
|
(4) | (depuis C++11) |
L'opération se comporte comme si
set_value
,
set_exception
,
set_value_at_thread_exit
, et
set_exception_at_thread_exit
acquéraient un mutex unique associé à l'objet promise lors de la mise à jour de l'objet promise.
Les appels à cette fonction n'introduisent pas de courses de données avec les appels à get_future (par conséquent, ils n'ont pas besoin de se synchroniser entre eux).
Table des matières |
Paramètres
| value | - | valeur à stocker dans l'état partagé |
Valeur de retour
(aucun)
Exceptions
std::future_error dans les conditions suivantes :
- * this n'a pas d'état partagé. Le code d'erreur est défini sur no_state .
- L'état partagé stocke déjà une valeur ou une exception. Le code d'erreur est défini sur promise_already_satisfied .
De plus :
R
.
R
.
Exemple
Cet exemple montre comment std:: promise < void > peut être utilisé comme signal entre les threads.
#include <algorithm> #include <cctype> #include <chrono> #include <future> #include <iostream> #include <iterator> #include <sstream> #include <thread> #include <vector> using namespace std::chrono_literals; int main() { std::istringstream iss_numbers{"3 4 1 42 23 -23 93 2 -289 93"}; std::istringstream iss_letters{" a 23 b,e a2 k k?a;si,ksa c"}; std::vector<int> numbers; std::vector<char> letters; std::promise<void> numbers_promise, letters_promise; auto numbers_ready = numbers_promise.get_future(); auto letter_ready = letters_promise.get_future(); std::thread value_reader([&] { // I/O operations std::copy(std::istream_iterator<int>{iss_numbers}, std::istream_iterator<int>{}, std::back_inserter(numbers)); // notify for numbers numbers_promise.set_value(); std::copy_if(std::istreambuf_iterator<char>{iss_letters}, std::istreambuf_iterator<char>{}, std::back_inserter(letters), ::isalpha); // notify for letters letters_promise.set_value(); }); numbers_ready.wait(); std::sort(numbers.begin(), numbers.end()); if (letter_ready.wait_for(1s) == std::future_status::timeout) { // output the numbers while letters are being obtained for (int num : numbers) std::cout << num << ' '; numbers.clear(); // numbers were already printed } letter_ready.wait(); std::sort(letters.begin(), letters.end()); // does nothing if numbers were already printed for (int num : numbers) std::cout << num << ' '; std::cout << '\n'; for (char let : letters) std::cout << let << ' '; std::cout << '\n'; value_reader.join(); }
Sortie :
-289 -23 1 2 3 4 23 42 93 93 a a a a b c e i k k k s s
Rapports de défauts
Les rapports de défauts modifiant le comportement suivants ont été appliqués rétroactivement aux normes C++ précédemment publiées.
| DR | Applicable à | Comportement publié | Comportement corrigé |
|---|---|---|---|
| LWG 2098 | C++11 |
les surcharges
(1,2)
ne pouvaient lever que les
exceptions levées par le constructeur de copie/déplacement de
R
respectivement
|
elles peuvent lever les exceptions
levées par le constructeur effectivement sélectionné pour copier/déplacer un objet de type
R
|
Voir aussi
|
définit le résultat à une valeur spécifique tout en délivrant la notification uniquement à la fin du thread
(fonction membre publique) |
|
|
définit le résultat pour indiquer une exception
(fonction membre publique) |