Namespaces
Variants

std::jthread:: jthread

From es.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
jthread ( ) noexcept ;
(1) (desde C++20)
jthread ( jthread && other ) noexcept ;
(2) (desde C++20)
template < class F, class ... Args >
explicit jthread ( F && f, Args && ... args ) ;
(3) (desde C++20)
jthread ( const jthread & ) = delete ;
(4) (desde C++20)

Construye un nuevo objeto std::jthread .

1) Crea un nuevo objeto std::jthread que no representa un hilo.
2) Constructor de movimiento. Construye el objeto std::jthread para representar el hilo de ejecución que estaba representado por other . Después de esta llamada, other ya no representa un hilo de ejecución.
3) Crea un nuevo objeto std::jthread y lo asocia con un hilo de ejecución.

El nuevo hilo de ejecución comienza ejecutando:

std:: invoke ( decay-copy ( std:: forward < F > ( f ) ) , get_stop_token ( ) ,
decay-copy ( std:: forward < Args > ( args ) ) ... )
(hasta C++23)

std:: invoke ( auto ( std:: forward < F > ( f ) ) , get_stop_token ( ) ,
auto ( std:: forward < Args > ( args ) ) ... )

(desde C++23)

si la expresión anterior está bien formada, de lo contrario comienza ejecutando:

std:: invoke ( decay-copy ( std:: forward < F > ( f ) ) ,
decay-copy ( std:: forward < Args > ( args ) ) ... )
.
(hasta C++23)

std:: invoke ( auto ( std:: forward < F > ( f ) ) ,
auto ( std:: forward < Args > ( args ) ) ... )
.

(desde C++23)
Las llamadas de decay-copy son evaluadas (until C++23) Los valores producidos por auto son materializados (since C++23) en el hilo actual, de modo que cualquier excepción lanzada durante la evaluación y copia/movimiento de los argumentos es lanzada en el hilo actual, sin iniciar el nuevo hilo.
Estas sobrecargas participan en la resolución de sobrecarga solo si std:: remove_cvref_t < F > no es el mismo tipo que std::jthread .
Si cualquiera de los siguientes es false , el programa está mal formado:
La finalización de la invocación del constructor se sincroniza con el inicio de la invocación de la copia de f en el nuevo hilo de ejecución.
4) El constructor de copia está eliminado; los hilos no son copiables. No hay dos std::jthread objetos que puedan representar el mismo hilo de ejecución.

Contenidos

Parámetros

otro - otro objeto std::jthread para construir este objeto std::jthread con
f - Callable objeto a ejecutar en el nuevo hilo
args - argumentos para pasar a la nueva función

Postcondiciones

1) get_id() igual a std::jthread::id() (es decir, joinable() devuelve false ) y get_stop_source ( ) . stop_possible ( ) es false .
2) other. get_id ( ) igual a std::jthread::id() y get_id() devuelve el valor de other. get_id ( ) previo al inicio de la construcción.
3) get_id() no es igual a std::jthread::id() (es decir, joinable() devuelve true ), y get_stop_source ( ) . stop_possible ( ) es true .

Excepciones

3) std::system_error si el hilo no pudo iniciarse. La excepción puede representar la condición de error std::errc::resource_unavailable_try_again u otra condición de error específica de la implementación.

Notas

Los argumentos de la función del hilo se mueven o copian por valor. Si es necesario pasar un argumento de referencia a la función del hilo, debe envolverse (por ejemplo, con std::ref o std::cref ).

Cualquier valor de retorno de la función es ignorado. Si la función lanza una excepción, std::terminate es llamado. Para pasar valores de retorno o excepciones de vuelta al hilo llamador, std::promise o std::async pueden ser utilizados.

Ejemplo

#include <chrono>
#include <iostream>
#include <thread>
#include <utility>
using namespace std::literals;
void f1(int n)
{
    for (int i = 0; i < 5; ++i)
    {
        std::cout << "Thread 1 executing\n";
        ++n;
        std::this_thread::sleep_for(10ms);
    }
}
void f2(int& n)
{
    for (int i = 0; i < 5; ++i)
    {
        std::cout << "Thread 2 executing\n";
        ++n;
        std::this_thread::sleep_for(10ms);
    }
}
class foo
{
public:
    void bar()
    {
        for (int i = 0; i < 5; ++i)
        {
            std::cout << "Thread 3 executing\n";
            ++n;
            std::this_thread::sleep_for(10ms);
        }
    }
    int n = 0;
};
class baz
{
public:
    void operator()()
    {
        for (int i = 0; i < 5; ++i)
        {
            std::cout << "Thread 4 executing\n";
            ++n;
            std::this_thread::sleep_for(10ms);
        }
    }
    int n = 0;
};
int main()
{
    int n = 0;
    foo f;
    baz b;
    std::jthread t0; // t0 no es un thread
    std::jthread t1(f1, n + 1); // paso por valor
    std::jthread t2a(f2, std::ref(n)); // paso por referencia
    std::jthread t2b(std::move(t2a)); // t2b ahora ejecuta f2(). t2a ya no es un thread
    std::jthread t3(&foo::bar, &f); // t3 ejecuta foo::bar() en el objeto f
    std::jthread t4(b); // t4 ejecuta baz::operator() en una copia del objeto b
    t1.join();
    t2b.join();
    t3.join();
    std::cout << "Final value of n is " << n << '\n';
    std::cout << "Final value of f.n (foo::n) is " << f.n << '\n';
    std::cout << "Final value of b.n (baz::n) is " << b.n << '\n';
    // t4 se une en la destrucción
}

Salida posible:

Thread 2 executing
Thread 1 executing
Thread 4 executing
Thread 3 executing
Thread 3 executing
Thread 4 executing
Thread 2 executing
Thread 1 executing
Thread 3 executing
Thread 1 executing
Thread 4 executing
Thread 2 executing
Thread 3 executing
Thread 1 executing
Thread 4 executing
Thread 2 executing
Thread 3 executing
Thread 1 executing
Thread 4 executing
Thread 2 executing
Final value of n is 5
Final value of f.n (foo::n) is 5
Final value of b.n (baz::n) is 0

Informes de defectos

Los siguientes informes de defectos que modifican el comportamiento se aplicaron retroactivamente a los estándares de C++ publicados anteriormente.

DR Aplicado a Comportamiento publicado Comportamiento correcto
LWG 3476 C++20 la sobrecarga (3) requería directamente que (los tipos decaídos de)
F y los tipos de argumento fueran moviblemente construibles
se eliminaron estos
requisitos [1]
  1. ↑ La capacidad de construcción por movimiento ya está indirectamente requerida por std::is_constructible_v .

Véase también

construye un nuevo objeto thread
(función miembro pública de std::thread )
Documentación C para thrd_create