std::packaged_task<R(Args...)>:: make_ready_at_thread_exit
|
|
|||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||||
| 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
)
;
|
(desde C++11) | |
Llama a la tarea almacenada como si fuera mediante INVOKE<R> ( f, args... ) , donde f es la tarea almacenada. El valor de retorno de la tarea o cualquier excepción lanzada por esta se almacena en el estado compartido de * this .
El estado compartido solo se prepara después de que el hilo actual finaliza y todos los objetos de duración de almacenamiento local de hilo son destruidos.
Contenidos |
Parámetros
| args | - | los parámetros a pasar en la invocación de la tarea almacenada |
Valor de retorno
(ninguno)
Excepciones
std::future_error en las siguientes condiciones de error:
-
La tarea almacenada ya ha sido invocada. La categoría de error se establece en
promise_already_satisfied. - * this no tiene estado compartido. La categoría de error se establece en no_state .
Ejemplo
#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(); // ejecutar tarea inmediatamente auto status = state->future.wait_for(std::chrono::seconds(0)); if (status == std::future_status::timeout) std::cout << "worker: el future aún no está listo\n"; else std::cout << "worker: el future está listo\n"; std::cout << "worker: salir\n"; } static std::shared_ptr<ProgramState> create_state() { auto state = std::make_shared<ProgramState>(); state->task = std::packaged_task<void()>{[] { std::cout << "task: ejecutado\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 finalizado\n"; auto status = state->future.wait_for(std::chrono::seconds(0)); if (status == std::future_status::timeout) std::cout << "main: el future aún no está listo\n"; else std::cout << "main: el future está listo\n"; }
Salida:
task: ejecutado worker: el future aún no está listo worker: salir main: worker finalizado main: el future está listo
Véase también
|
ejecuta la función
(función miembro pública) |