线程支持库(C++11)

线程支持库包含了线程,互斥锁,线程条件变量(class thread),定义于<thread>

线程提供一个并发的实例,需要对应一个“线程函数”

线程的主要任务就是去执行这个"线程函数"


既然线程需要提供一个线程函数,在线程实例化的时候,需要一个"线程函数"

        构造一个线程类的对象,需要提供一个参数(线程函数)

C++的线程类就是包装了POSIX标准的线程接口,所以在编译的时候需要链接多线程库
        -lpthread


最基本的用法:

        thread t{线程函数,线程函数的参数......};// 实例化一个线程对象,创建成功之后,就会自动运行
       
t.join();// 等待线程退出

01 线程类的用法(创建一个线程,让新创建的线程完成指定的功能)

(1) 线程函数是全局函数

#include <iostream>
#include <thread>using namespace std;// 全局的线程函数(按值传递)
void print_arg(int a) {int c = 10;while (c--) {cout << "a:" << a++ <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}
}// 全局的线程函数(按引用传递)
void print_arg1(int & a) { // a成为你实际传入的参数的别名int c = 10;while (c--) {cout << "a:" << a++ <<endl;//线程休眠一段时间this_thread::sleep_for(1s);}
}int main() {// 实例化一个线程对象,自动开始运行// thread t{线程函数, 线程函数的参数};int n = 10;// thread t{print_arg, n}; // 创建一个线程,按值传递参数thread t{print_arg1, std::ref(n)}; // 创建一个线程,按引用传递参数// 传参的时候,指定n以引用的方式传递给线程的构造函数/*thread(线程函数地址, int x = n) { // 线程的构造函数pthread_create(...线程函数地址,&x);}*/// 完成其他的任务int c = 10;while (c--) {cout << "hello" <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}// 等待线程结束t.join(); // 阻塞cout << "n:" << n << endl;return 0;
}

(2) 线程函数是类的static函数

        类的static函数

                a. 可以通过类名调用

                b. 没有this指针

                c. 只能访问类的静态成员(不能访问类的非static成员)

        

        使用方式:

                thread t{类名::静态成员函数名,线程函数的参数};

// 线程函数是类的static函数#include <iostream>
#include <thread>using namespace std;class A {public:// 线程函数(按值传递)static void print_arg(int a) {int c = 10;while (c--) {cout << "a:" << a++ <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}}// 线程函数(按引用传递)static void print_arg1(int & a) { // a成为你实际传入的参数的别名int c = 10;while (c--) {cout << "a:" << a++ <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}}
};int main() {// 实例化一个线程对象,自动开始运行// thread t{线程函数, 线程函数的参数};int n = 10;// A::print_arg()// thread t{A::print_arg, n}; // 创建一个线程,按值传递参数thread t{A::print_arg1, std::ref(n)}; // 创建一个线程,按引用传递参数// 传参的时候,指定n以引用的方式传递给线程的构造函数// 完成其他的任务int c = 10;while (c--) {cout << "hello" <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}// 等待线程结束t.join(); // 阻塞cout << "n:" << n << endl;return 0;
}

(3) 线程函数是类的普通成员函数

        普通的全局函数和静态函数都可以直接调用,不需要通过对象,但是类的普通成员函数不能直接调用,必须通过对象调用(因为有一个隐式的参数:this)

        所以,当一个类的非静态成员函数作为线程函数时,我们需要传递一个该类的对象的地址作为this指针的实参

                语法:

                        thread t{&类名::成员函数名,该类对象的地址,线程函数的参数};

// 线程函数是类的非static函数#include <iostream>
#include <thread>using namespace std;class A {public:// 线程函数(按值传递)void print_arg(int a) {int c = 10;while (c--) {cout << "a:" << a++ <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}}// 线程函数(按引用传递)void print_arg1(int & a) { // a成为你实际传入的参数的别名int c = 10;while (c--) {cout << "a:" << a++ <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}}
};int main() {// 实例化一个线程对象,自动开始运行// thread t{线程函数, 线程函数的参数};int n = 10;A a; // 实例化一个对象// a.print_arg(n) -----> print_arg(&a, n)// thread t{&A::print_arg, &a, n}; // 创建一个线程,按值传递参数thread t{&A::print_arg1, &a, std::ref(n)}; // 创建一个线程,按引用传递参数// 传参的时候,指定n以引用的方式传递给线程的构造函数// 完成其他的任务int c = 10;while (c--) {cout << "hello" <<endl;// 线程休眠一段时间this_thread::sleep_for(1s);}// 等待线程结束t.join(); // 阻塞cout << "n:" << n << endl;return 0;
}

以上三种就是线程最普通的用法

02 线程互斥锁(mutex)

线程互斥锁是用来避免多个并发实例对共享资源的访问产生竞争,定义于头文件<mutex>

class mutex;

class timed_mutex;


std::mutex 既不可以复制,也不可以移动(删除了operator=,也没有实现移动构造函数)
默认构造函数可以初始化一个锁对象,默认是处于解锁状态的

函数:

        lock        上锁,阻塞到获取锁

        try_lock        尝试获取锁,获取失败则返回false

        unlock        解锁


用法:

        mutex m;// 实例化一个锁对象

        

        m.lock(); // 访问共享资源前上锁    m.try_lock();

        ......; // 访问共享资源的代码(临界区)

        m.unlock(); // 访问完共享资源后解锁

#include <iostream>
#include <thread>
#include <mutex>using namespace std;mutex m; // 全局的锁// 全局的共享资源
int x = 0;// 是一个不可重入的函数
void add_x() {int c = 1000000;while (c--) {// while (!m.try_lock()); // 上锁m.lock();x++; // 共享资源m.unlock(); }
}int main() {// 实例化一个线程对象,自动开始运行thread t1{add_x}; thread t2{add_x};   // 等待线程结束t1.join(); // 阻塞t2.join(); // 阻塞cout << "x:" << x << endl;return 0;
}

mutex,timed_mutex ...... 可以单独使用,但是可能会遇到一些问题
如:

        (1) 程序员不注意,造成了"带锁退出"  ------> deadlock        

                xxx() {

                        m.lock();

                        ......

                        if (...) {

                                return ;

                        }

                        m.unlock();

                }

        (2) 同时获取多个锁,推进的顺序不一样

                xxx() {

                        m1.lock();

                        m2.lock();

                        ......

                        ......

                        m2.unlock();

                        m1.unlock();

                }

                

                yyy() {

                        m2.lock();

                        m1.lock();

                        ......

                        ......

                        m1.unlock();

                        m2.unlock();

                }

                基于这样的原因,C++标准库中,提供了一些互斥锁的包裹类

                        常用的是:

                                std::lock_guard<std::mutex> guard{m};

                                std::unique_lock<std::mutex> lock{m};

                可以自动的管理指定的锁,在代码作用域结束后,可以自动的释放指定的锁,可以防止带锁退出

                如:

                        mutex m; // 普通的互斥锁,默认是处于解锁状态的

                        { // 描述的是一个作用域范围

                                std::lock_guard<std::mutex> guard{m}; // 使用一个管理对象guard管理锁m

                                // ...... 临界区代码

                                return ;

                        }

                        上面的代码是使用lock_guard类型去管理m这个锁,当构造guard的时候自动的给m表示的锁上锁,当guard超出作用域范围后,guard管理的锁自动的解锁

#include <iostream>
#include <thread>
#include <mutex>using namespace std;mutex m; // 全局的锁// 全局的共享资源
int x = 0;// 是一个不可重入的函数
void add_x() {int c = 1000000;while (c--) {lock_guard<mutex> g{m}; // 使用包裹类对象g管理m表示的锁x++; // 共享资源}
}int main() {// 实例化一个线程对象,自动开始运行thread t1{add_x}; thread t2{add_x};   // 等待线程结束t1.join(); // 阻塞t2.join(); // 阻塞cout << "x:" << x << endl;return 0;
}

        unique_lock是lock_guard的升级版,提供了额外的接口

        也能够在超出作用域范围之后,自动的释放管理的锁

        用于指定锁定策略的标签常量(常量):

                defer_lock

                try_to_lock

                adopt_lock

        但是还有一些额外的功能:

        如:

                1. 同时获取多个锁

                        mutex m1,m2;

                        {

                                // 希望同时获取m1和m2,要么都获取成功,要么都不成功

                                // 创建之后,实际上没有获取锁

                                std::unique_lock<std::mutex> lock1{m1, std::defer_lock};

                                std::unique_lock<std::mutex> lock2{m2, std::defer_lock};

                                        

                                // 同时获取lock1和lock2表示的两个锁

                                std::lock(lock1, lock2); // 同时获取

                                // ......临界区代码        

                        }

                

                2. 管理锁住的粒度(操作共享资源的代码块的大小)

                        void add_x1()

                        {

                                int c = 100000;

                                // explicit unique_lock( mutex_type & m);

                                // 没加参数表示构造的时候获取锁

                                std::unique_lock<std::mutex> lock{m}; // 构造的时候上锁

                                while (c--)

                                {

                                        x++;

                                        lock.unlock(); // 手动释放锁

                                        scanf("......");

                                        lock.lock(); // 手动加锁

                                }

                        }

03 线程条件变量

线程可以等待一个程序员人为设置的一个"条件"


条件不满足的时候,线程可以等待这个条件,当条件满足的时候,线程可以继续往下运行

定义于头文件 <condition_variable>

class condition_variable

能够阻塞一个线程,或者同时阻塞多个线程,直到条件变量表示的”条件“成立,并且被其他地方通知
======>

        用于”生产者-消费者“模式

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>using namespace std;mutex m; // 全局的锁
condition_variable cond; // 条件变量,表示程序员抽象出来的一个条件// 全局的共享资源
int x = 0;// 生产者函数
void add_x() {while (1) {// while (!m.try_lock()); // 上锁m.lock();x++; // 生产数据cout << "生产者:" << x << endl;if (x > 5) { // 表示满足消费条件,应该通知消费者消费数据cout << "通知消费者!" << endl;cond.notify_all(); // 通知所有等待的线程}m.unlock();this_thread::sleep_for(1s);  }
}// 生产者函数
// void add_x() {
//     while (1) {
//         // while (!m.try_lock()); // 上锁
//         m.lock();
//         x++; // 生产数据
//         cout << "生产者:" << x << endl;
//         m.unlock();
//         this_thread::sleep_for(1s);
//     }
// }// 消费者函数
void delete_x() {while (1) {// 没加参数表示构造的时候获取锁unique_lock<mutex> lk{m}; // 构造的时候上锁if (x > 5) {x = x - 5; // 消费数据cout << "消费者:" << x << endl;} else {cout << "我在浪费CPU!" << endl;cout << "等待一个条件" << endl;cond.wait(lk); // 原子的解锁lock,阻塞等待cond表示的条件}}  
}// 消费者函数
// void delete_x() {
//     while (1) {
//         // while (!m.try_lock());
//         m.lock();
//         if (x >= 5) {
//             x = x - 5; // 消费数据
//             cout << "消费者:" << x << endl;
//         } else {
//             cout << "我在浪费CPU!" << endl;
//         }
//         m.unlock();
//         this_thread::sleep_for(1s);
//     }  
// }int main() {// 实例化一个线程对象,自动开始运行thread t1{add_x}; thread t2{delete_x};   // 等待线程结束t1.join(); // 阻塞t2.join(); // 阻塞return 0;
}

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

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

相关文章

ApsaraMQ Serverless 能力再升级,事件驱动架构赋能 AI 应用

本文整理于 2024 年云栖大会阿里云智能集团高级技术专家金吉祥&#xff08;牟羽&#xff09;带来的主题演讲《ApsaraMQ Serverless 能力再升级&#xff0c;事件驱动架构赋能 AI 应用》 云消息队列 ApsaraMQ 全系列产品 Serverless 化&#xff0c;支持按量付费、自适应弹性、跨可…

一款专业获取 iOS 设备的 UDID 工具|一键获取iPhone iPad设备的 UDID

什么是UDID&#xff1f; UDID&#xff0c;是iOS设备的一个唯一识别码&#xff0c;每台iOS设备都有一个独一无二的编码&#xff0c;这个编码&#xff0c;我们称之为识别码&#xff0c;也叫做UDID&#xff08; Unique Device Identifier&#xff09; 扫描后系统提示输入密码&am…

IDEA连接EXPRESS版本的SQL server数据库

我安装的版本是SQL2019-SSEI-Expr.exe 也就是EXPRESS版本的SQL Server安排非常简单和快速。 但是默认没有启动sa用户。 启动sa用户名密码登录 默认安装完以后没有启用。 使用Miscrosoft SQL Server Management Studio 使用Windows身份连接后。 在安全性》登录名中找到sa并修改…

PHP如何实现过滤用户输入

在PHP中&#xff0c;过滤用户输入是确保应用程序安全性的关键步骤之一。通过过滤用户输入&#xff0c;可以防止诸如SQL注入、XSS攻击等安全漏洞。 1. 使用PHP内置函数 1.1 filter_var() filter_var()函数是PHP中用于验证和过滤用户输入的主要函数之一。它允许你指定一个变量…

大模型,多模态大模型面试问题【计算图,LLama,交叉熵,SiLU,RLHF】

大模型&#xff0c;多模态大模型面试问题【计算图&#xff0c;LLama&#xff0c;交叉熵&#xff0c;SiLU&#xff0c;RLHF】 问题一&#xff1a;讲一讲计算图中pytorch是什么&#xff0c;TensorFlow是什么&#xff1f;1. PyTorch2. TensorFlow区别总结 问题二&#xff1a;Llama…

【AIGC】2024-arXiv-Lumiere:视频生成的时空扩散模型

2024-arXiv-Lumiere: A Space-Time Diffusion Model for Video Generation Lumiere&#xff1a;视频生成的时空扩散模型摘要1. 引言2. 相关工作3. Lumiere3.1 时空 U-Net (STUnet)3.2 空间超分辨率的多重扩散 4. 应用4.1 风格化生成4.2 条件生成 5. 评估和比较5.1 定性评估5.2 …

如何使用python完成最简单的数据预测?

数据预测是数据科学和机器学习中的一个重要领域。通过分析历史数据,我们可以预测未来的趋势和结果。 本文将介绍如何使用Python进行最简单的数据预测,包括基本的概念、常用的库和一个简单的代码示例。 1. 数据预测的基本概念 数据预测是利用历史数据来预测未来事件的过程。…

k8s集群 ceph rbd 存储动态扩容

k8s 集群 rbd 扩容有两种方法&#xff0c;如下所示 通过StorageClass自动扩容 # kubectl get sc csi-rbd-sc -oyaml|grep allowVolumeExpansion allowVolumeExpansion: true如果搜索有如上字段&#xff0c;说明是可以自动扩容的&#xff0c;修改对应要扩容的 PVC容量&#xf…

如何通过接口版本控制实现向后兼容

目录 引言接口版本控制策略实现方案最佳实践常见问题与解决方案总结与建议 1. 引言 在微服务架构中&#xff0c;接口的版本控制是一个不可回避的话题。如何在保持系统稳定性的同时&#xff0c;实现接口的平滑升级&#xff1f;如何确保新版本的发布不会影响现有用户&#xff…

隨筆 20241025 Kafka数据一致性的韭菜比喻

在Kafka中&#xff0c;数据一致性是通过Leader和Follower副本之间的协调来实现的。为了更容易理解这个复杂的概念&#xff0c;我们可以用韭菜作为比喻。 韭菜的角色 Leader韭菜&#xff1a;代表数据的主导者&#xff0c;它负责更新和维护最新的数据。Follower韭菜&#xff1a…

【CPN TOOLS建模学习】设置变迁的属性

使用Tab键在属性之间进行切换 与一个变迁相关联的四个铭文&#xff0c;均为可选项&#xff1a; 变迁名称守卫(Guard)时间代码段 变迁延迟必须是一个正整数表达式。该表达式前面加上&#xff0c;这意味着时间铭文的形式为 delayexpr。在添加时间铭文之前&#xff0c;铭文的默…

uniapp 如何调用音频

uniapp调用音频 button点击 <view><button click"startPlay">开始播放</button></view>方法实现 startPlay() { const innerAudioContext uni.createInnerAudioContext();innerAudioContext.src /static/sounds/oqc.mp3;innerAudioContex…

【Mac】Homebrew

1、Homebrew 简介 官网地址&#xff1a;https://brew.sh Homebrew 是一款Mac OS平台下的软件包管理工具&#xff0c;拥有安装、卸载、更新、查看、搜索等很多实用的功能。 Homebrew 主要有四个部分组成: brew、homebrew-core 、homebrew-bottles、homebrew-cask。 源说明br…

标准正态分布的数据 tensorflow 实现正态分布图,python 编程,数据分析和人工智能...

登录后复制 import tensorflow as tfimport matplotlib.pyplot as plt# 设置随机种子以获得可重复的结果tf.random.set_seed(42)# 生成正态分布的数据# mean0 和 stddev1 表示生成标准正态分布的数据# shape(1000,) 表示生成1000个数据点data tf.random.normal(mean0, stddev1…

005 IP地址的分类

拓扑结构如下 两台主机处于同一个网关下&#xff0c;通过ping命令检测&#xff0c;可以连通 &nbps; 拓扑结构如下 使用ping 检查两台电脑是否相通, 因为网络号不一样&#xff0c;表示两台电脑不在同一个网络&#xff0c;因此无法连通 拓扑结构如下 不在同一网络的PC要相…

thinkphp6 redis 哈希存储方式以及操作函数(笔记)

逻辑&#xff1a;如果redis里没有指定表数据就进行存储再输出&#xff0c;如果有就直接输出&#xff0c;代码优化后几万条数据从数据库入redis也是三四秒的时间&#xff0c;数据以json方式存储&#xff1a;key用于数据ID 跟数据库数据ID同步&#xff0c;value用于存储整个字段包…

HTML--浮动布局练习

<!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>Document</title><style>/* 整个浏览器页…

后台管理系统的通用权限解决方案(二)SpringBoot整合Swagger Springfox实现接口日志文档

文章目录 1 Swagger介绍2 Swagger常用注解3 Swagger使用案例 1 Swagger介绍 使用Swagger&#xff0c;我们只需要按照它的规范去定义接口及接口相关的信息&#xff0c;再通过Swagger衍生出来的一系列项目和工具&#xff0c;就可以做到生成各种格式的接口文档&#xff0c;生成多…

【Spring框架】Spring框架的开发方式

目录 Spring框架开发方式前言具体案例导入依赖创建数据库表结构创建实体类编写持久层接口和实现类编写业务层接口和实现类配置文件的编写 IoC注解开发注解开发入门&#xff08;半注解&#xff09;IoC常用注解Spring纯注解方式开发 Spring整合JUnit测试 Spring框架开发方式 前言…