Namespaces
Variants

std::packaged_task<R(Args...)>:: make_ready_at_thread_exit

From cppreference.net
Concurrency support library
Threads
(C++11)
(C++20)
this_thread namespace
(C++11)
(C++11)
Cooperative cancellation
Mutual exclusion
Generic lock management
Condition variables
(C++11)
Semaphores
Latches and Barriers
(C++20)
(C++20)
Futures
(C++11)
(C++11)
(C++11)
Safe reclamation
Hazard pointers
Atomic types
(C++11)
(C++20)
Initialization of atomic types
(C++11) (deprecated in C++20)
(C++11) (deprecated in C++20)
Memory ordering
(C++11) (deprecated in C++26)
Free functions for atomic operations
Free functions for atomic flags
void make_ready_at_thread_exit ( ArgTypes... args ) ;
(C++11以降)

保存されたタスクを、あたかも INVOKE<R> ( f, args... ) によって呼び出すかのように実行する。ここで f は保存されたタスクである。タスクの戻り値、またはタスクによってスローされた例外は、 * this の共有状態に保存される。

共有状態は、現在のスレッドが終了し、スレッドローカルストレージ期間を持つすべてのオブジェクトが破棄された後にのみ準備完了状態となります。

目次

パラメータ

args - 格納されたタスクの呼び出し時に渡すパラメータ

戻り値

(なし)

例外

std::future_error が以下のエラー条件で発生します:

  • 格納されたタスクは既に呼び出されています。エラーカテゴリは promise_already_satisfied に設定されています。
  • * this は共有状態を持ちません。エラーカテゴリは no_state に設定されています。

#include <chrono>
#include <functional>
#include <future>
#include <iostream>
#include <memory>
#include <thread>
#include <utility>
struct ProgramState
{
    std::packaged_task<void()> task;
    std::future<void> future;
    std::thread worker;
};
static void worker(std::shared_ptr<ProgramState> state)
{
    state->task.make_ready_at_thread_exit(); // タスクを即時実行
    auto status = state->future.wait_for(std::chrono::seconds(0));
    if (status == std::future_status::timeout)
        std::cout << "worker: future is not ready yet\n";
    else
        std::cout << "worker: future is ready\n";
    std::cout << "worker: exit\n";
}
static std::shared_ptr<ProgramState> create_state()
{
    auto state = std::make_shared<ProgramState>();
    state->task = std::packaged_task<void()>{[]
    {
        std::cout << "task: executed\n";
    }};
    state->future = state->task.get_future();
    state->worker = std::thread{worker, state};
    return state;
}
int main()
{
    auto state = create_state();
    state->worker.join();
    std::cout << "main: worker finished\n";
    auto status = state->future.wait_for(std::chrono::seconds(0));
    if (status == std::future_status::timeout)
        std::cout << "main: future is not ready yet\n";
    else
        std::cout << "main: future is ready\n";
}

出力:

task: executed
worker: future is not ready yet
worker: exit
main: worker finished
main: future is ready

関連項目

関数を実行する
(public member function)