std:: promise

クラステンプレート std::promise は、後で非同期に取得される値または例外を格納する機能を提供します。これは、 std::promise オブジェクトによって作成された std::future オブジェクトを介して行われます。 std::promise オブジェクトは一度だけ使用されることを意図していることに注意してください。

各プロミスは shared state に関連付けられており、これにはいくつかの状態情報と、まだ評価されていない値（voidの場合もあり）、値として評価された結果、または例外として評価された結果である result が含まれます。プロミスはshared stateに対して3つの操作を行うことができます：

• make ready : promiseは結果または例外を共有状態に格納します。状態をreadyに設定し、共有状態に関連付けられたfutureを待機しているスレッドのブロックを解除します。
• release : promiseは共有状態への参照を放棄します。これが最後の参照であった場合、共有状態は破棄されます。これがまだreadyになっていない std:: async によって作成された共有状態でない限り、この操作はブロックしません。
• abandon : promiseは std::future_error 型の例外をエラーコード std::future_errc::broken_promise で格納し、共有状態を ready にした後、 release します。

promiseはpromise-future通信チャネルの「push」側である：共有状態に値を格納する操作は、 synchronizes-with （ std::memory_order で定義される通り）共有状態を待機する任意の関数（例えば std::future::get など）からの正常復帰と同期する。同じ共有状態への並行アクセスは、それ以外の場合には競合する可能性がある：例えば std::shared_future::get の複数の呼び出し元は、すべて読み取り専用であるか、外部同期を提供しなければならない。

メンバー関数

非メンバー関数

ヘルパークラス

例

#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); // futureに通知
}
void do_work(std::promise<void> barrier)
{
    std::this_thread::sleep_for(std::chrono::seconds(1));
    barrier.set_value();
}
int main()
{
    // promise<int>を使用してスレッド間で結果を伝達するデモンストレーション
    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));
    // future::get()はfutureが有効な結果を持つまで待機し、それを取得します
    // get()の前にwait()を呼び出す必要はありません
    // accumulate_future.wait(); // 結果を待機
    std::cout << "result=" << accumulate_future.get() << '\n';
    work_thread.join(); // スレッドの完了を待機
    // promise<void>を使用してスレッド間で状態を通知するデモンストレーション
    std::promise<void> barrier;
    std::future<void> barrier_future = barrier.get_future();
    std::thread new_work_thread(do_work, std::move(barrier));
    barrier_future.wait();
    new_work_thread.join();
}

result=21