std::jthread::jthread

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 对象。新的执行线程开始执行： {{rev|until=c++23|

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 的调用会在当前线程求值 (C++23 前)auto 产生的值会在当前线程实质化 (C++23 起)，所以实参的求值和复制/移动中抛出的任何异常都会在当前线程抛出，而不会开始新线程。

这些重载只有在 std::remove_cvref_t<F> 和 std::jthread 不是同一类型时才会参与重载决议。

如果以下任意值是 false，那么程序非良构：

std::is_constructible_v<std::decay_t<F>, F>
(std::is_constructible_v<std::decay_t<Args>, Args> && ...)
std::is_invocable_v<std::decay_t<F>, std::decay_t<Args>...> ||
std::is_invocable_v<std::decay_t<F>, std::stop_token, std::decay_t<Args>...>

构造函数的调用完成同步于新的执行线程上 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 << "正在执行线程 1\n";
        ++n;
        std::this_thread::sleep_for(10ms);
    }
}
 
void f2(int& n)
{
    for (int i = 0; i < 5; ++i)
    {
        std::cout << "正在执行线程 2\n";
        ++n;
        std::this_thread::sleep_for(10ms);
    }
}
 
class foo
{
public:
    void bar()
    {
        for (int i = 0; i < 5; ++i)
        {
            std::cout << "正在执行线程 3\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 << "正在执行线程 4\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 在对象 f 上运行 foo::bar()
    std::jthread t4(b); // t4 在对象 b 的副本上运行 baz::operator()
    t1.join();
    t2b.join();
    t3.join();
    std::cout << "n 的最终值是 " << n << '\n';
    std::cout << "f.n (foo::n) 的最终值是 " << f.n << '\n';
    std::cout << "b.n (baz::n) 的最终值是 " << b.n << '\n';
    // t4 在析构时合并
}

可能的输出：

正在执行线程 2
正在执行线程 1
正在执行线程 4
正在执行线程 3
正在执行线程 3
正在执行线程 4
正在执行线程 2
正在执行线程 1
正在执行线程 3
正在执行线程 1
正在执行线程 4
正在执行线程 2
正在执行线程 3
正在执行线程 1
正在执行线程 4
正在执行线程 2
正在执行线程 3
正在执行线程 1
正在执行线程 4
正在执行线程 2
n 的最终值是 5
f.n (foo::n) 的最终值是 5
b.n (baz::n) 的最终值是 0

缺陷报告

下列更改行为的缺陷报告追溯地应用于以前出版的 C++ 标准。

缺陷报告	应用于	出版时的行为	正确行为
LWG 3476	C++20	重载 (3) 直接要求 `F` 和实参类型（在退化后）必须可移动构造	移除这些要求^[1]

↑ std::is_constructible_v 已间接要求了可移动构造性。

参阅

(构造函数)

构造新的 thread 对象
(std::thread 的公开成员函数)

[1] std::is_constructible_v 已间接要求了可移动构造性。

[1]

编译器支持
自立实现与有宿主实现
语言
标准库
标准库标头
具名要求
功能特性测试宏 (C++20)
语言支持库
概念库 (C++20)
元编程库 (C++11)
诊断库
通用工具库
字符串库
容器库
迭代器库
范围库 (C++20)
算法库
数值库
本地化库
输入/输出库
文件系统库 (C++17)
正则表达式库 (C++11)
并发支持库 (C++11)
技术规范
符号索引
外部库

成员函数
jthread::jthread
jthread::~jthread
jthread::operator=
观察器
jthread::joinable
jthread::get_id
jthread::native_handle
jthread::hardware_concurrency
操作
jthread::join
jthread::detach
jthread::swap
停止状态处理
jthread::get_stop_source
jthread::get_stop_token
jthread::request_stop
非成员函数
swap(std::jthread)

std::jthread::jthread

参数

后条件

异常

注解

示例

缺陷报告

参阅

导航