std::packaged_task<R(Args...)>:: make_ready_at_thread_exit
From cppreference.net
<
cpp
|
thread
|
packaged task
C++
Concurrency support library
|
|
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
std::packaged_task
| Member functions | ||||
| Getting the result | ||||
| Execution | ||||
|
packaged_task::make_ready_at_thread_exit
|
||||
| Non-member functions | ||||
| Helper classes | ||||
|
(until C++17)
|
||||
| Deduction guides (C++17) |
|
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) |