【C++】多线程编程二(std::thread详解)

news2024/11/27 10:28:29

目录

std::thread详解

(1)启动线程

①无参无返回的函数作为入参

②函数对象(仿函数)作为入参

(2)不等待线程detch()

(3)等待线程完成join()

(4)向线程函数传递参数

(5) 转移线程所有权

(6)标识线程id


std::thread详解

每个程序至少有一个线程:执行main()函数的线程,其余线程有其各自的入口函数。线程与原始线程(以main()函数为入口函数的线程)同时运行。如同main()函数执行完退出一样,当线程执行完入口函数后,线程也会退出。在为一个线程创建了一个 std::thread 对象后,需要等待这个线程结束。

(1)启动线程

线程在 std::thread  对象创建(为线程创建指定任务)时启动。使用C++线程库启动线程就是构造 std::thread  对象。使用时需要引入头文件 <thread> 。

std::thread 构造函数:

构造函数语法格式备注
默认构造函数thread() noexcept;创建一个空的std::thread 对象
初始化构造函数template <class Fn, class... Args>
explicit thread(Fn&& fn, Args&&... args);
创建一个std::thread 对象该对象可以被joinable,新产生的线程会调用fn函数,该函数的参数由 args 给出。
拷贝构造函数[delete]thread(const thread&) = delete;禁用,std::thread 对象不可拷贝构造
移动构造函数thread(thread&& x) noexcept;调用成功之后,x就不代表任何thread对象了

①无参无返回的函数作为入参

#include <thread>

void do_work();
std::thread mythread(do_work);

do_work()函数在其所属的线程上允许,直到函数执行完毕,线程也就结束了。

②函数对象(仿函数)作为入参

#include <iostream>
#include <thread>
using namespace std;

class Test
{
public:
	void operator()()const
	{
		cout << "hello world" << endl;
	}
};

int main()
{
    //Lambda表达式创建的匿名函数对象
	thread mythread([] {cout << "hello world" << endl; });

    //1和2都是函数对象
	//thread testthread((Test())); //1
	thread testthread{ Test() };//2 新统一的函数对象初始化语法
	mythread.join();
	testthread.join();
}

启动线程后,需要明确是等待线程结束(join)还是让其自主运行(deatch)。

必须在 std::thread 对象销毁之前做出决定,否则程序就会终止( std::thread 的析构函数函数会调用 std::terminate(),这时再决定会触发相应的异常)。

  • detach方式,启动的线程自主在后台运行,当前的代码继续往下执行,不等待新线程结束。
  • join方式,等待启动的线程完成,才会继续往下执行。

(2)不等待线程detch()

detach()线程: 将当前线程对象所代表的执行实例与该线程对象分离,使得线程的执行可以单独进行。一旦线程执行完毕,它所分配的资源将会被释放。

调用 detach 函数之后:

  • *this 不再代表任何的线程执行实例。
  • joinable() == false
  • get_id() == std::thread::id()

另外,如果出错或者 joinable() == false,则会抛出 std::system_error。

示例演示:

void thread01()
{
    for (int i = 0; i < 5; i++)
    {
        cout << "Thread 01 is working !" << endl;
        Sleep(10);
    }
}
void thread02()
{
    for (int i = 0; i < 5; i++)
    {
        cout << "Thread 02 is working !" << endl;
        Sleep(20);
    }
}

int main()
{
    thread task01(thread01);
    thread task02(thread02);
    task01.detach();
    task02.detach();

    for (int i = 0; i < 5; i++)
    {
        cout << "Main thread is working !" << endl;
        Sleep(20);
    }

 由上图主线程结果和子线程结果无规则输出可知,detach方式主线程和子线程是自主运行的,互不干扰。

如果不等待线程,就必须保证线程结束之前,可访问的数据的有效性。例如:对象销毁之后再去访问,就会产生未定义的错误。这种情况很可能发生再线程还没结束,函数已经退出的时候,这时线程函数还持有函数局部变量的指针或引用。

class func
{
public:
    int& i;
    func(int& i_) : i(i_) {}
    void operator() ()
    {
        for (unsigned j = 0; j < 1000000; ++j)
        {
            do_something(i);           // 1 潜在访问隐患:悬空引用
        }
    }
};

void oops()
{
    int some_local_state = 0;
    func my_func(some_local_state);
    std::thread my_thread(my_func);
    my_thread.detach();          // 2 不等待线程结束
}                               // 3 新线程可能还在运行

//如果线程还行运行,就会调用do_something(i)函数,就会访问一个已经销毁的变量。

解决方案:将数据复制到线程中,而非复制到共享数据中。

也可以通过join()函数来确保线程在函数完成前结束。

(3)等待线程完成join()

如果需要等待线程,可以使用join()函数。 my_thread.detach()改为my_thread.join() 就可以确保局部变量在线程完成后才销毁。调用join()的行为,还清理了线程相关的存储部分,这样 thread 对象将不再与已经完成的线程有关联。这意味着,只能对一个线程使用一次join();一旦使用过join(),thread 对象就不能再次join(),当对其使用joinable()时,将返回false。

 示例演示:

void thread01()
{
    for (int i = 0; i < 5; i++)
    {
        cout << "Thread 01 is working !" << endl;
        Sleep(10);
    }
}
void thread02()
{
    for (int i = 0; i < 5; i++)
    {
        cout << "Thread 02 is working !" << endl;
        Sleep(20);
    }
}

int main()
{
    thread task01(thread01);
    thread task02(thread02);
    task01.join();
    task02.join();

    for (int i = 0; i < 5; i++)
    {
        cout << "Main thread is working !" << endl;
        Sleep(20);
    }

}

 

 由上图主线程结果都在子线程结果后面输出可知,join使得调用thread01()和thread02()的线程task01和task02发生阻塞,直到由阻塞的线程执行完毕后,主线程才执行。

joinable(): 检查线程是否可被 join。检查当前的线程对象是否表示了一个活动的执行线程,由默认构造函数创建的线程是不能被 join 的。另外,如果某个线程已经执行完任务,但是没有被 join 的话,该线程依然会被认为是一个活动的执行线程,因此也是可以被 join 的。

【小结】

如果想要分离一个线程,可以在线程启动后,直接使用detach() 进行分离。

如果打算等待对应的线程,则需要挑选join()的位置。当在线程运行之后产生异常,在join()调用之前抛出,就意味着这次调用会被跳过。

(4)向线程函数传递参数

创建std::thread 对象时,向构造函数中的可调用对象或函数传递参数,和普通的函数差不多,对应函数参数顺序依次传入即可。

【注意】默认参数是以引用的形式拷贝到线程独立内存中。

#include <iostream>
#include <thread>

void func1(int a)
{
    a = 100;
    cout << "func1:" << a << endl;
}

void func2(int& a)
{
    a = 100;
    cout <<"func2:"<< a << endl;
}

int main()
{
    int a = 10;
    std::thread t1(func1, a);//++++++++ 1 编译成功
//通过初始化构造函数,创建了一个std::thread对象t1,新产生的进程会调用func1,该函数的参数为a
    t1.join();
    cout <<"Main:"<< a << endl;

    //std::thread t2(func2, a);//++++++++2 编译失败
    std::thread t2(func2, std::ref(a));//++++++3  编译成功
    t2.join();
    cout <<"Main:" << a << endl;
    
    a++;
    std::thread t3(func2, std::ref(a));
    std::thread t4(std::move(t3));//++++++++++4  编译成功
    t4.join();
    cout << "Main:" << a << endl;
 
}

 ①中使用std::thread 构造函数创建对象t1时,参数a是以拷贝进行值传递的,所以子进程对a的修改,只对子进程独立内存中的a起作用,并不影响主进程的a。

func2 期待传入一个引用参数,但是std::thread 的构造函数2并不知晓;构造函数无视函数期待的参数类型,并盲目的拷贝已提供的变量。代码将参数以右值的方式进行拷贝传递,并被函数func2调用。因为函数期待是一个非常量引用作为参数,而非一个右值作为参数,所以编译时出错。

解决方案:使用 std::ref 将参数转换成引用的形式。如3所示即可。

③中参数是引用方式传递,相当于子进程和主进程共享参数a,所以子进程对参数a的修改,同样影响了主进程的a.

④中使用移动构造函数将t3对象的资源移动给t4,t3不再是thread对象,不起作用了,func2在线程对象t4正常运行,并由于是引用传递,所以也更改了主线程a的值。

(5) 转移线程所有权

上面示例4中运用到了一个移动 std::move操作。C++标准库中有许多资源占有类型,比如 std::ifstream ,std::unique_ptr和std::thread 都是可移动的,但不可拷贝。当要写一个后台启动线程的函数,并想通过新线程返回的所有权去调用这个函数,而不是等待线程结束再去掉用。

void some_function();
void some_other_function();
std::thread t1(some_function);            // 1
std::thread t2=std::move(t1);            // 2
t1=std::thread(some_other_function);    // 3

新线程开始与t1相关联①。当显式使用std::move创建t2后②,t1的所有权就转移给了t2。之后,t1和执行线程已经没有关联了,执行some_function的函数线程与t2关联。

然后,一个临时std::thread 对象相关的线程启动了③。为什么不显式调用std::move()转移所有权呢?因为,所有者是一个临时对象——移动操作将会隐式的调用。

std::thread 赋值操作:

函数名称函数原型备注
移动赋值thread& operator=(thread&& rhs) noexcept;移动赋值,如果当前对象不可joinable,需要传递一个右值引用给move赋值操作;如果当前对象可被joinable,则会调用terminate()报错。
拷贝赋值thread& operator=(const thread&) = delete;被禁用,所以std::thread对象不可拷贝
std::thread t3;                            // 4
t3=std::move(t2);                        // 5
t1=std::move(t3);                        // 6 赋值操作将使程序崩溃

t3使用默认构造方式创建④,与任何执行线程都没有关联。调用 std::move()将与t2关联线程的所有权转移到t3中⑤。因为t2是一个命名对象,需要显式的调用std::move()。移动操作 #5 完成后,t1与执行some_other_function的线程相关联,t2与任何线程都无关联,t3与执行some_function的线程相关联。

最后一个移动操作,将some_function线程的所有权转移⑥给t1。不过,t1已经有了一个关联的线程(执行some_other_function的线程),所以这里系统直接调用std::terminate()终止程序继续运行。这样做(不抛出异常,std::terminate()是noexcept函数)是为了保证与std::thread的析构函数的行为一致(说明:不能通过赋一个新值给std::thread对象的方式来”丢弃”一个线程)。

 线程的所有权转移场景

①函数返回std::thread 对象(所有权在函数外进行转移)

void do_task()
{
    cout << "do_task" << endl;
}
std::thread function()
{
    void do_task();
    return std::thread(do_task);
}

int main()
{
    std::thread task01 = function();
    task01.join();
    cout << "main end" << endl;
}

②std::thread 对象作为参数 (所有权在函数内部传递)

void do_task()
{
    cout << "do_task" << endl;
}

void function(std::thread t)
{
    t.join();
}

int main()
{
    std::thread t(do_task);
    function(std::move(t));
    cout << "main end" << endl;
}

(6)标识线程id

线程标识类型为 std::thread::id ,可以通过两种方式进行检索。

一是,通过调用std::thread对象的成员函数 get_id () 来直接获取。如果std::thread对象没有与任何线程相关联,get_id()将返回std::thread::type 默认值,这个值表示“无线程”。

二是,当前线程中调用 std::this_thread::get_id() ,这个函数定义在<thread>头文件中,也可以获得线程标识。

std::thread::id对象可以自由拷贝和对比,因为标识符可以复用。

如果两个对象的id相等,那么它们是同一个线程,或都是“无线程”。如果不等,那就代表两个不同线程,或一个有线程,另一个没有线程。

void do_master_task() {
    cout << "do master task" << endl;
}

void do_other_task() {
    cout << "do other task" << endl;
}


int main()
{
    std::thread::id master_id = std::this_thread::get_id();
    thread mythread([] {cout << "open child thread" << endl; });
    mythread.join();
    if (std::this_thread::get_id() == master_id)
    {
        do_master_task();
    }
    else {
        do_other_task();
    }
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/759826.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

CANoe如何配置Master/Slave模式

系列文章目录 文章目录 系列文章目录前言一、CANoe配置端口二、CANoe配置Master模式三、CANoe配置Slave模式前言 随着智能电动汽车的行业的发展,车载以太网的应用越来越广泛,最近很多朋友在问CANoe Master/Slave模式如何设置,车载以太网物理层也有一项是测试Master/Slave模式…

springcloud整合nacos实现注册发现中心

文章目录 微服务为什么需要服务注册发现中心怎么使用注册发现中心1.本示例环境2.nacos 安装3.pom.xml4.application.yml5.NacosDiscoveryDemoController6.ServerConfig7.NacosNacosDiscoveryServiceImpl8.启动用http工具测试结果 如果需要完整源码请关注公众号"架构殿堂&q…

2023.7.16-偶数(奇数)的枚举

功能&#xff1a;输入一个整数&#xff0c;结果打印出所有不大于这个整数的偶数。 程序&#xff1a; #define _CRT_SECURE_NO_WARNINGS 1 #include<stdio.h> int main() {int a, b;printf("请输入一个整数&#xff1a;");scanf("%d",&a);print…

Android之Intent

意图介绍 一个意图(Intent)对象包含了目标组件、动作、数据、类别、附加数据、标志六个部分。 目标组件 目标组件可以帮助应用发送显式意图调用请求。在创建Intent时&#xff0c;可以通过setComponent方法来设置一个组件&#xff0c;如&#xff1a; //设置组件 intent.setC…

19.基于XML的自动装配

基于XML的自动装配 自动装配&#xff1a; 根据指定的策略&#xff0c;在IOC容器中匹配某一个bean&#xff0c;自动为指定的bean中所依赖的类类型或接口类型属性赋值 使用bean标签的autowire属性设置自动装配效果(默认为no和defalse不进行装配——bean中的属性不会自动匹配某个b…

Nodejs的字节操作(Buffer)

Hi I’m Shendi Nodejs的字节操作&#xff08;Buffer&#xff09; 字节操作是一个编程语言中必不可少的&#xff0c;而在NodeJs中也可以很方便的进行字节操作。 Buffer类 在 js 中没有二进制数据类型&#xff0c;但在一些情况下必须使用到二进制数据类型&#xff0c;比如网络通…

ModaHub魔搭社区:AI原生云向量数据库Zilliz Cloud与 OpenAI 集成搭建相似性搜索系统

目录 准备工作 检索图书 本文将讨论如何使用 OpenAI 的 Embedding API 与 Zilliz Cloud 搭建相似性搜索系统。 在本篇中你将看到如何使用 OpenAI 的 Embedding API 和 Zilliz Cloud 完成图书检索。当前,很多的图书检索方案,包括公共图书馆里使用的那些方案,都是使用关键词…

简单认识MySQL数据库事务

文章目录 一、MySQL事务的概念1、简介2、事务的ACID特点1.原子性&#xff08;Atomicity&#xff09;2.一致性&#xff08;Consistency&#xff09;3.隔离性&#xff08;lsolation&#xff09;4.持久性&#xff08;Durability) 3、并发访问表的一致性问题和事务的隔离级别1.并发…

C# Modbus通信从入门到精通(6)——Modbus RTU(0x04功能码)

1、04(0x04)读输入寄存器 使用该功能码能从远程地址中读取1到125个输入寄存器的值,每个输入寄存器都占两个字节,读取的输入寄存器数量由主站读取时指定。 2、发送报文格式 更详细的格式如下: 从站地址+功能码+起始地址高位+起始地址低位+寄存器数量高位+寄存器数量低位+…

备战求战 | 笔试强训6

目录 一、选择题 二、编程题 三、选择题题解 四、编程题题解 一、选择题 1、十进制变量i的值为100&#xff0c;那么八进制的变量i的值为&#xff08;&#xff09; A. 146 B. 148 C. 144 D. 142 2、执行下面语句后的输出为 int I1; if(I<0)printf("****\n") …

全志F1C200S嵌入式驱动开发(串口驱动)

【 声明:版权所有,欢迎转载,请勿用于商业用途。 联系信箱:feixiaoxing @163.com】 对于uboot、kernel和rootfs来说,他们的串口输出一般都是uart0。一般这么做,是没有问题的。只不过我们自己买的这块f1c200s电路板,设计者把uart转ttl的接口,改接到了uart1上面。…

自定义注解+AOP完成公共字段填充

在开发中&#xff0c;我们的实体类经常会有几个公共的字段&#xff0c;如下图的创建时间&#xff0c;修改时间就为各个类共有的字段&#xff1a; 目前项目中处理这些字段都是在每一个业务方法中进行赋值操作,如下: 如果都按照上述的操作方式来处理这些公共字段, 需要在每一个业…

中级课程——信息收集(完结)

文章目录 概要whois备案号警告CDN历史解析查询子域名查询后台目录指纹C段&#xff0c;旁站真实IP与CDN端口证书其他资产社工漏洞情报实操案例 概要 whois 备案号 警告 CDN历史解析查询 子域名查询 工具推荐 或者找在线工具 后台目录 指纹 C段&#xff0c;旁站 真实IP与CDN 端…

无符号数和数据类型转换

无符号数 字符类型的无符号值&#xff1a; 所有的数据底层都是采用二进制来保存&#xff0c;而第一位用于保存符号位&#xff0c;当不考虑符号位时&#xff0c;所有的数都按照数值进行保存 #include <stdio.h>int main() {unsigned char a -65;printf("%u"…

JVM结构-堆

堆不是一种数据结构&#xff08;什么结构都可以存放在堆中&#xff09;堆内存的大小是可以调节的。类加载器读取了类文件后&#xff0c;需要把类、方法、常变量放到堆内存中&#xff0c;保存所有引用类型的真实信息JVM堆被同一个JVM实例中的所有Java线程共享JVM堆通常由某种自动…

Redis的过期策略以及内存淘汰机制

目录 一、过期策略1.1、定时删除1.1.1、过期1.1.2、过期的 key 集合1.1.3、定时扫描策略1.1.4、 Redis 中所有的 key 在同一时间过期了&#xff0c;会出现怎样的结果1.1.5、从库的过期策略 1.2、惰性删除1.3、定时删除和惰性删除的总结 二、缓存淘汰算法2.1、缓存淘汰算法概述2…

mysql 备份

mysql 备份 1. 备份的类型2.备份的类容3. 备份工具1&#xff1a;MySQL自带的备份工具2&#xff1a;文件系统备份工具3&#xff1a;其他工具 4:备份的策略1. 直接拷贝数据库文件2. mysqldump备份数据库3. mydumper备份数据库4.lvm快照从物理角度实现几乎热备的完全备份&#xff…

【Dart】006-类的定义和使用

【Dart】006-类的定义和使用 文章目录 【Dart】006-类的定义和使用一、类的定义1、概述2、简单定义与实例化代码示例运行结果 3、成员方法代码示例运行结果箭头函数写法 4、get 与 set 关键字概述代码示例运行结果 二、类的构造方法1、特点2、完整版的构造方法简化版完整版 3、…

关于K8s的Pod的详解(一)

关于K8s的Pod的详解&#xff08;一&#xff09; Pod和API server的通信加快Pod启动更改Pod的资源Pod 的持久卷的单个访问模式Pod 拓扑分布约束Pod 拓扑分布中的最小域数 Pod 作为k8s创建&#xff0c;调度&#xff0c;管理的基本单位。由上级的Controller对Node上安装的Kubelet发…

最全整理,Pytest自动化测试框架-用例参数/忽略用例/失败重试(实战)

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 测试用例参数化 …