std::packaged_task<R(Args...)>::make_ready_at_thread_exit
From cppreference.com
< cpp | thread | packaged task
| 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(); // execute task right away 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) |
