std::jthread::jthread

来自cppreference.com
< cpp‎ | thread‎ | jthread
 
 
并发支持库
线程
(C++11)
(C++20)
(C++20)
this_thread 命名空间
(C++11)
(C++11)
(C++11)
原子类型
(C++11)
(C++20)
原子类型的初始化
(C++11)(C++20 中弃用)
(C++11)(C++20 中弃用)
原子操作的自由函数
原子标志的自由函数
内存序
互斥
(C++11)
通用锁管理
(C++11)
(C++11)
(C++11)
(C++11)(C++11)(C++11)
(C++11)
(C++11)
条件变量
(C++11)
信号量
闩与屏障
(C++20)
(C++20)
future
(C++11)
(C++11)
(C++11)
(C++11)
 
 
jthread() noexcept;
(1) (C++20 起)
jthread( jthread&& other ) noexcept;
(2) (C++20 起)
template< class Function, class... Args >
explicit jthread( Function&& 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<Function>(f)), get_stop_token(),
            decay-copy(std::forward<Args>(args))...)

(C++23 前)

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

(C++23 起)

如果以上表达式非良构,那么就会开始执行:

std::invoke(decay-copy(std::forward<Function>(f)),
            decay-copy(std::forward<Args>(args))...)

(C++23 前)

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

(C++23 起)
decay-copy 的调用会在当前线程求值 (C++23 前)auto 产生的值会在当前线程实质化 (C++23 起),所以任何求值和复制/移动参数中抛出的异常都会抛出到当前线程,而不会开始新线程。如果任何构造或 std::invoke 非法,那么程序非良构。
如果 std::remove_cvref_t<Function>std::jthread 是同一类型,那么此构造函数不会参与重载决议。
构造函数的调用完成同步于(定义见 std::memory_order)新的执行线程上 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::refstd::cref)。

忽略来自函数的任何返回值。如果函数抛出异常,那么就会调用 std::terminate。需要将返回值或异常传递回调用方线程时可以使用 std::promisestd::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

参阅

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