std::promise<R>::set_value
From cppreference.com
| メインテンプレート |
||
| void set_value( const R& value ); |
(1) | (C++11以降) |
| void set_value( R&& value ); |
(2) | (C++11以降) |
| std::promise<R&> の特殊化 |
||
| void set_value( R& value ); |
(3) | (C++11以降) |
| std::promise<void> の特殊化 |
||
| void set_value(); |
(4) | (C++11以降) |
1-3) value を共有状態にアトミックに格納し、状態を ready にします。
4) 状態を ready にします。
この操作は、`set_value`、set_exception、set_value_at_thread_exit、および set_exception_at_thread_exit が、プロミスオブジェクトに関連付けられた単一のミューテックスを、プロミスオブジェクトを更新する間、獲得するのと同様に動作します。
この関数への呼び出しは、get_future への呼び出しとのデータ競合を発生させません（したがって、互いに同期する必要はありません）。
目次 |
[編集] パラメータ
| value | - | 共有状態に格納する値 |
[編集] 戻り値
(なし)
[編集] 例外
std::future_error は、以下の条件で発生します。
- *this が共有状態を持たない場合。エラーコードは no_state に設定されます。
- 共有状態が既に値または例外を格納している場合。エラーコードは promise_already_satisfied に設定されます。
さらに
1) 型 `R` のオブジェクトをコピーするコンストラクタで発生した例外。
2) 型 `R` のオブジェクトをムーブするコンストラクタで発生した例外。
[編集] 例
この例では、std::promise<void> をスレッド間のシグナルとして使用する方法を示しています。
このコードを実行
#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(); }
出力
-289 -23 1 2 3 4 23 42 93 93 a a a a b c e i k k k s s
[編集] 不具合報告
以下の動作変更を伴う欠陥報告が、以前に公開されたC++標準に遡って適用されました。
| DR | 適用対象 | 公開された動作 | 正しい動作 |
|---|---|---|---|
| LWG 2098 | C++11 | オーバーロード (1,2) は、それぞれ コピー/ムーブコンストラクタで発生する 例外のみをスローできる |
実際には、選択されたコンストラクタで発生する 例外をスローできる 型 `R` のオブジェクトをコピー/ムーブする。 |
[編集] 関連項目
| スレッド終了時のみ通知を配信し、結果を特定の値に設定する (public member function) | |
| 結果が例外を示すように設定する (public member function) |
