名前空間
変種
操作

std::promise<R>::set_value

提供: cppreference.com
< cpp‎ | thread‎ | promise
 
 
スレッドサポートライブラリ
スレッド
(C++11)
(C++20)
(C++20)
this_thread 名前空間
(C++11)
(C++11)
(C++11)
相互排他
(C++11)
汎用ロック管理
(C++11)
(C++11)
(C++11)
(C++11)(C++11)(C++11)
(C++11)
(C++11)
条件変数
(C++11)
セマフォ
ラッチとバリア
(C++20)
(C++20)
フューチャー
(C++11)
(C++11)
(C++11)
(C++11)
 
 
void set_value( const R& value );
(1) (汎用 promise テンプレートのみのメンバ)
(C++11以上)
void set_value( R&& value );
(2) (汎用 promise テンプレートのみのメンバ)
(C++11以上)
void set_value( R& value );
(3) (promise<R&> テンプレート特殊化のみのメンバ)
(C++11以上)
void set_value();
(4) (promise<void> テンプレート特殊化のみのメンバ)
(C++11以上)
1-3) アトミックに value を共有状態に格納し準備完了にします。
4) 状態を準備完了にします。

操作は set_valueset_exceptionset_value_at_thread_exitset_exception_at_thread_exit が promise オブジェクトを更新する間 promise オブジェクトに紐付けられている単一のミューテックスを取得するかのように動作します。

共有状態がない、または共有状態がすでに値や例外を格納している場合は、例外が投げられます。

この関数の呼び出しは get_future の呼び出しとのデータ競合を発生しません (それらはお互いに同期する必要はありません)。

目次

[編集] 引数

value - 共有状態に格納する値

[編集] 戻り値

(なし)

[編集] 例外

以下の状況で std::future_error が投げられます。

  • *this が共有状態を持っていない。 エラーカテゴリは no_state に設定されます。
  • 共有状態にすでに値や例外が格納されている。 エラーカテゴリは promise_already_satisfied に設定されます。

さらに、

1, 3) value のコピーコンストラクタによって投げられるあらゆる例外を投げます。
2) value のムーブコンストラクタによって投げられるあらゆる例外を投げます。

[編集]

この例はスレッド間の信号として promise<void> をどのように使用できるかを示します。

#include <thread>
#include <future>
#include <cctype>
#include <vector>
#include <algorithm>
#include <iterator>
#include <iostream>
#include <sstream>
 
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(std::chrono::seconds(1)) ==
            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());
 
    //If numbers were already printed, it does nothing.
    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

[編集] 関連項目

例外を表す結果を設定します
(パブリックメンバ関数) [edit]