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 ) ;
(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)