当前位置:首页 > 公众号精选 > 程序喵大人
[导读]近期看到有读者在公众号留言问有没有C多线程的学习方法,我这里特意总结了下,希望能对大家有所帮助。目录什么是多线程?为什么使用多线程?如何创建线程?joinable()?多线程参数传递方式锁原子变量条件变量async多线程周边关于多线程的一些建议什么是多线程?不介绍,基础知识,直接...

近期看到有读者在公众号留言问有没有C 多线程的学习方法,我这里特意总结了下,希望能对大家有所帮助。



目录

  • 什么是多线程?

  • 为什么使用多线程?

  • 如何创建线程?

  • joinable()?

  • 多线程参数传递方式

  • 原子变量

  • 条件变量

  • async

  • 多线程周边

  • 关于多线程的一些建议



什么是多线程?

不介绍,基础知识,直接看维基百科:https://zh.wikipedia.org/wiki/多线程

为什么要用多线程?

不介绍,基础知识,和上面在一个链接。



C 多线程知识点


如何创建线程?

多线程有多种创建方式:pthread、std::thread、std::jthread。


这里我推荐学习C 11引入的std::thread,它较pthread更方便,且在C 中更加常用。


至于std::jthread,不用管,学完std::thread后自然就能学会std::jthread。


关于C 11的多线程具体介绍可以看c 11新特性之线程相关所有知识点


使用std::thread创建线程很简单,直接利用它的构造函数即可:

void func() { xxxx;}
int main() { std::thread t(func); if (t.joinable()) { t.join(); } return 0;}注意上面代码,我使用了一个joinable()和join(),为什么要这么做?


因为如果不这么调用,在thread生命周期结束时,程序会crash。原因直接看thread的析构函数:

~thread(){ if (joinable()) std::terminate();}

join()和detach()?

上面介绍了不调用join,程序会crash,其实也可以调用detach来避免程序crash,那它俩有什么区别?


join()表示阻塞等待子线程执行结束,子线程结束后才会继续往下执行。


detach()表示与当前对象分离,子线程无论做啥,无论是否执行结束都与我无关,爱咋咋地,最终靠操作系统回收相关资源。


joinable()是什么?

上面代码中出现了joinable(),可以简单理解为如果没有调用join()或者detach(),joinable()就返回true。如果调用了其中一个,joinable()就返回false。它主要就是为了搭配join()和detach()使用。


参数传递问题

多线程其实就是开启一个线程,运行某一个函数,上面的示例是运行的无参函数,那如何运行有参函数?怎么将参数传递进去?其实有好几种方法传递参数,我更倾向于使用的是lambda表达式,将有参函数 参数封装成无参函数,然后多线程调用。


示例代码:

#include #include
void func(int a, int b) { std::cout << "a b = " << a b << std::endl; }
int main() { auto lambda = []() { func(1, 2); }; std::thread t(lambda); if (t.joinable()) { t.join(); } return 0;}

关于lambda表达式我之前写过文章介绍,可以看这里:


搞定c 11新特性std::function和lambda表达式

编译器如何实现lambda表达式?


成员函数问题

很多人可能还有疑问,如果多线程运行类对象的成员函数,这里可以使用和上面相同的方法,lambda表达式:

#include #include #include
struct A { void Print() { std::cout << "A\n"; }};
int main() { std::shared_ptr a = std::make_shared(); auto func = [a]() { a->Print(); }; std::thread t(func); if (t.joinable()) { t.join(); } return 0;}


小知识点


创建thread对象的常见方法有下面这两种:


std::thread a(func);
std::thread *a = new thread(func);delete a;

有人在技术交流群里问过这两种方式的区别,相信仔细阅读过上面内容的你应该知道答案!

给个小提示:两者对象一个在堆上,一个在栈上,生命周期不同,即thread的析构函数调用时机不同,然后可以再结合上面介绍的~thread()的实现,思考一下。

为什么需要锁?

因为多线程读写数据可能存在线程安全问题,为了保证线程安全,其中一种方式就是使用锁。

关于线程安全问题,随便去个网站,比如维基百科、百度百科等,都能找到。

https://zh.wikipedia.org/wiki/线程安全


mutex有四种:

  • std::mutex:独占的互斥量,不能递归使用,不带超时功能

  • std::recursive_mutex:递归互斥量,可重入,不带超时功能

  • std::timed_mutex:带超时的互斥量,不能递归

  • std::recursive_timed_mutex:带超时的互斥量,可以递归使用


加解锁方式有三种:

  • std::lock_guard:可以RAII方式加锁

  • std::unique_lock:比lock_guard多了个手动加解锁的功能

  • std::scoped_lock:防止多个锁顺序问题导致的死锁问题而出世的一把锁


示例代码:

std::mutex mutex; void func() { std::lock_guard lock(mutex); xxxxxxx}

原子操作

上面介绍过使用锁可以解决线程安全问题,其实简单的变量,比如整型变量等,可以使用原子操作,C 11的原子操作都在中。


示例代码:

std::atomic<int> count;
int get() { count.load();}
void set(int c) { count.store(c);}

上面这两个函数可以在多线程中任意调用,不会出现线程安全问题。


条件变量

条件变量是一种同步机制,可以阻塞一个线程或多个线程,直到其他线程对这些线程通知才会解除阻塞。这种通知和阻塞就需要用到条件变量。


示例代码:

class CountDownLatch { public: explicit CountDownLatch(uint32_t count) : count_(count);
void CountDown() { std::unique_lock lock(mutex_); --count_; if (count_ == 0) { cv_.notify_all(); } }
void Await(uint32_t time_ms = 0) { std::unique_lock lock(mutex_); while (count_ > 0) { if (time_ms > 0) { cv_.wait_for(lock, std::chrono::milliseconds(time_ms)); } else { cv_.wait(lock); } } }
uint32_t GetCount() const { std::unique_lock lock(mutex_); return count_; }
private: std::condition_variable cv_; mutable std::mutex mutex_; uint32_t count_ = 0;};

有关条件变量其实有两个坑需要注意,移步这里:使用条件变量的坑你知道吗


基于任务的并发

这块个人认为只需要了解async即可,通过async既可以达到并发的目的,也可以拿到并发执行后的结果。


示例代码:

#include #include #include #include
using namespace std;
int func(int in) { return in 1; }
int main() { auto res = std::async(func, 5); cout << res.get() << endl; // 阻塞直到函数返回 return 0;}

具体可以看:c 11新特性之线程相关所有知识点


也可以看我利用此种方式写的线程池:C 11线程池


其他


如何使线程休眠?


可以利用std::this_thread和chrono,它俩搭配使得线程休眠很方便,而且休眠时间也很清晰。可不像C语言的sleep,我每次使用C语言的sleep时都会特意去搜索一下,单位究竟是秒还是毫秒。

std::this_thread::sleep_for(std::chrono::milliseconds(10));

线程个数问题


很多人都会纠结线程池开多少个线程效率最高的问题,假设CPU个数为N,有的资料会介绍N个线程效率最高,有的资料会介绍2N个线程效率最高。在中通过以下函数可以获取CPU的个数:

static unsigned hardware_concurrency() noexcept;

至于需要开多少个线程,个人认为需要根据个性化需求实际测试,你测出来多少个线程性能最高,就开多少个线程。


死锁

死锁的定义可直接维基百科:https://zh.wikipedia.org/wiki/死锁

至于如何解决死锁,可以看:多线程中如何使用gdb精确定位死锁问题


我关于多线程还有一些建议,推荐大家看这个:


最后,在我学习多线程的过程中,发现了一篇介绍C 11多线程非常详细的博客,也推荐大家看看。


博客链接:https://www.cnblogs.com/haippy/p/3284540.html





手撸一个对象池


这里收集了100多篇C 原创文章(入门进阶必备)


if-else和switch-case哪个效率更高?看这四张图。


从未见过把内存玩的如此明白的文章(推荐大家都来看看)


写出高效代码的12条建议


推荐几个开源库



分享

收藏

点赞

在看


本站声明: 本文章由作者或相关机构授权发布,目的在于传递更多信息,并不代表本站赞同其观点,本站亦不保证或承诺内容真实性等。需要转载请联系该专栏作者,如若文章内容侵犯您的权益,请及时联系本站删除。
换一批
延伸阅读

我们手里每天基本都有多个事情要做,很多人为了在短时间内完成任务,于是,开启了“多线程”工作模式。比如:一边写代码,一边写工作总结,同时还在回复着工作群里的消息。

关键字: 多线程 工作阻力 代码

摘要:针对计算机端口扫描技术的优缺点,采用多线程技术,结合TCP全连接扫描,实现了基于C语言编程的网络端口扫描及危险端口关闭程序,旨在使端口关闭操作简单化。

关键字: 多线程 危险端口 简单化

摘要:阐述了一种基于GPRS和嵌入式Linux的远程图像监控系统设计和实现方法。该系统主要由嵌入式视频采集终端 和监控中心服务器组成。其中,嵌入式视频采集终端主要由摄像头视频采集模块、ARM模块、SIM900模块组成,监...

关键字: 通用分组无线业务 实时图像采集 多线程 信号量

一、前言二、MichaHofri算法三、测试代码四、总结一、前言在上一篇文章中,介绍了一种纯软件算法,用来实现临界区的保护功能,文章链接:C语言边角料2:用纯软件来代替Mutex互斥锁。首先明确一下:如果利用操作系统提供...

关键字: C语言 多线程 软件

作 者:道哥,10年嵌入式开发老兵,专注于:C/C、嵌入式、Linux。关注下方公众号,回复【书籍】,获取Linux、嵌入式领域经典书籍;回复【PDF】,获取所有原创文章(PDF格式)。目录单片机中常用的环形缓冲区多线程...

关键字: 多线程 异步

|前言前两天做了一个导入的功能,导入开始的时候非常慢,导入2w条数据要1分多钟,后来一点一点的优化,从直接把list怼进Mysql中,到分配把list导入Mysql中,到多线程把list导入Mysql中。时间是一点一点的...

关键字: 多线程

直接进入正题,发车!简述java内存模型(JMM)java内存模型定义了程序中各种变量的访问规则。其规定所有变量都存储在主内存,线程均有自己的工作内存。工作内存中保存被该线程使用的变量的主内存副本,线程对变量的所有操作都...

关键字: 多线程

直接进入正题,发车!简述java内存模型(JMM)java内存模型定义了程序中各种变量的访问规则。其规定所有变量都存储在主内存,线程均有自己的工作内存。工作内存中保存被该线程使用的变量的主内存副本,线程对变量的所有操作都...

关键字: 多线程

直奔主题,多个线程,一个共享变量,不断1。如果代码直接这样写,会产生线程安全问题。public class LongAdder {   private long count = 0L;   public void ad...

关键字: 多线程

Redis官方在2020年5月正式推出6.0版本,提供很多振奋人心的新特性,所以备受关注。❝码老湿,提供了啥特性呀?知道了我能加薪么?主要特性如下:多线程处理网络IO;客户端缓存;细粒度权限控制(ACL);RESP3协议...

关键字: 多线程 模型
关闭
关闭