Namespaces
Variants

std::jthread:: jthread

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
jthread ( ) noexcept ;
(1) (начиная с C++20)
jthread ( jthread && other ) noexcept ;
(2) (начиная с C++20)
template < class F, class ... Args >
explicit jthread ( F && f, Args && ... args ) ;
(3) (начиная с C++20)
jthread ( const jthread & ) = delete ;
(4) (начиная с C++20)

Создает новый объект std::jthread .

1) Создает новый объект std::jthread , который не представляет поток выполнения.
2) Конструктор перемещения. Создает объект std::jthread для представления потока выполнения, который был представлен объектом other . После этого вызова other больше не представляет поток выполнения.
3) Создает новый объект std::jthread и связывает его с потоком выполнения.

Новый поток выполнения начинает выполнение:

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

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

(начиная с C++23)

если приведенное выше выражение корректно, в противном случае начинает выполнение:

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

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

(начиная с C++23)
Вызовы decay-copy вычисляются (until C++23) Значения, произведённые с помощью auto подвергаются материализации (since C++23) в текущем потоке, так что любые исключения, возникающие во время вычисления и копирования/перемещения аргументов, выбрасываются в текущем потоке, без запуска нового потока.
Эти перегрузки участвуют в разрешении перегрузки только если std:: remove_cvref_t < F > не является тем же типом, что и std::jthread .
Если любое из следующих условий false , программа является некорректной:
Завершение вызова конструктора синхронизируется с началом вызова копии f в новом потоке выполнения.
4) Конструктор копирования удален; потоки не могут быть скопированы. Никакие два std::jthread объекта не могут представлять один и тот же поток выполнения.

Содержание

Параметры

other - другой std::jthread объект для конструирования данного std::jthread объекта
f - Callable объект для выполнения в новом потоке
args - аргументы для передачи в новую функцию

Постусловия

1) get_id() равно std::jthread::id() (т.е. joinable() возвращает false ) и get_stop_source ( ) . stop_possible ( ) равно false .
2) other. get_id ( ) равно std::jthread::id() и get_id() возвращает значение other. get_id ( ) до начала конструирования.
3) get_id() не равен std::jthread::id() (т.е. joinable() возвращает true ), и get_stop_source ( ) . stop_possible ( ) равно true .

Исключения

3) std::system_error если поток не может быть запущен. Исключение может представлять код ошибки std::errc::resource_unavailable_try_again или другую реализационно-зависимую ошибку.

Примечания

Аргументы функции потока перемещаются или копируются по значению. Если необходимо передать в функцию потока ссылочный аргумент, его следует обернуть (например, с помощью std::ref или std::cref ).

Любое возвращаемое значение функции игнорируется. Если функция выбрасывает исключение, std::terminate вызывается. Для передачи возвращаемых значений или исключений обратно в вызывающий поток, std::promise или std::async могут быть использованы.

Пример

#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 не является потоком
    std::jthread t1(f1, n + 1); // передача по значению
    std::jthread t2a(f2, std::ref(n)); // передача по ссылке
    std::jthread t2b(std::move(t2a)); // t2b теперь выполняет f2(). t2a больше не является потоком
    std::jthread t3(&foo::bar, &f); // t3 выполняет foo::bar() на объекте f
    std::jthread t4(b); // t4 выполняет baz::operator() на копии объекта 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 присоединяется при уничтожении
}

Возможный вывод:

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

Отчеты о дефектах

Следующие отчеты об изменениях поведения, влияющие на дефекты, были применены ретроактивно к ранее опубликованным стандартам C++.

DR Применяется к Поведение в опубликованной версии Корректное поведение
LWG 3476 C++20 перегрузка (3) напрямую требовала (деградировавшие типы)
F и типы аргументов были конструируемыми при перемещении
удалены эти
требования [1]
  1. Возможность перемещающего конструирования уже косвенно требуется std::is_constructible_v .

Смотрите также

создает новый объект thread
(публичная функция-член std::thread )
Документация C для thrd_create