C++多线程快速入门（一）：基本常用操作

目录

    • case1：创建线程1 join、detach
    • case2：创建线程2 线程传参 传值或者传引用
    • case3：创建线程 线程传参 functional object作为参数
    • case4：观察多线程程序加速计算
    • case5：future + get 获取并发结果
    • case6：互斥锁
    • case7：std::lock_guard 类模板

case1：创建线程1 join、detach

创建线程，并等该线程执行完毕,并且打印两个线程的id

#include <iostream>
#include <thread>
using namespace std;
void func() {cout << "hello , this is my thread, thread id is " << this_thread::get_id() << endl;
}
int main() {thread th = thread(func);th.join();cout << "this is main thread and its id is " << this_thread::get_id() << endl;
}

执行结果如下：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
hello , this is my thread, thread id is 2
this is main thread and its id is 1Process finished with exit code 0

使用detach，放弃对该线程的控制：

#include <iostream>
#include <thread>using namespace std;void func() {cout << "hello , this is my thread, thread id is " << this_thread::get_id() << endl;
}
int main() {thread th = thread(func);th.detach();// 如果我们此时不再关系该线程的运行情况的话可以使用detachcout << th.joinable() << endl;cout << "this is main thread and its id is " << this_thread::get_id() << endl;
}

运行结果：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
0
this is main thread and its id is 1
hello , this is my thread, thread id is 2Process finished with exit code 0

case2：创建线程2 线程传参 传值或者传引用

传值

#include <iostream>
#include <thread>using namespace std;void func(string s) {cout << "hello , this is my thread, thread arg is " << s << endl;
}
int main() {thread th = thread(func, "test");th.join();cout << "this is main thread and its id is " << this_thread::get_id() << endl;
}

打印结果如下：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
hello , this is my thread, thread arg is test
this is main thread and its id is 1Process finished with exit code 0

传引用

#include <iostream>
#include <thread>using namespace std;void func(string& s) {cout << (&s) << endl;cout << "hello , this is my thread, thread arg is " << s << endl;
}
int main() {string str = "test";thread th = thread(func, ref(str));cout << (&str) << endl;th.join();cout << "this is main thread and its id is " << this_thread::get_id() << endl;
}

打印结果如下：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
0x62fd10
0x62fd10
hello , this is my thread, thread arg is test
this is main thread and its id is 1Process finished with exit code 0

case3：创建线程 线程传参 functional object作为参数

关于仿函数的定义可以看：仿函数
如果单纯地将逻辑函数传入thread，在函数逻辑比较复杂的时候不太好。
将函数封装到类的内部，可以赋予一定的封装性，并且可以在类内部创建例如map的数据结构来记录函数运行的状态。
仿函数、不带参

#include <iostream>
#include <thread>using namespace std;// functional object
struct A {void operator()() {cout << "I'm A" << endl;}
};
void show() {cout << "I'm show" << endl;
}
int main() {show();A a;a();    // 等价于 a.operator()();// 我们把这种object称为callable的object ，又称为仿函数thread thread1 = thread(A());thread1.join();return 0;
}

打印结果如下：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
I'm show
I'm A
I'm AProcess finished with exit code 0

仿函数、带参

#include <iostream>
#include <thread>using namespace std;// functional object
struct A {void operator()(int num) {for (int i = 0; i < num; i++) {cout << "I'm A" << i << endl;}}
};int main() {int num = 10;thread thread1 = thread(A(), num);for (int i = 0; i < num; i++) {cout << "I'm main" << i << endl;}thread1.join();return 0;
}

打印结果如下，是乱序的，符合多线程特性
并且 cout 并不是线程安全的，所以可以发现，有乱码的样子

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
I'm mainI'm A00I'm A1
I'm A2
I'm A3
I'm AI'm main41I'm mainI'm A25I'm mainI'm A36I'm AI'm main47I'm main5
I'm mainI'm A86I'm mainI'm A97I'm main8
I'm main9Process finished with exit code 0

lambda函数作为参数

#include <iostream>
#include <thread>using namespace std;int main() {string s = "test";thread f = thread([&s](int a,int b) {cout << s << endl;cout << a + b << endl;}, 2, 3);f.join();return 0;
}

打印结果：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
test
5Process finished with exit code 0

case4：观察多线程程序加速计算

#include <iostream>
#include <thread>using namespace std;// 测量一个函数的运行时间
template <class T>
void measure(T&& func) {using namespace std::chrono;auto start = system_clock::now();// funcfunc();duration<double> diff = system_clock::now() - start;cout << "执行了" << diff.count() << "秒" << endl;
}// 求和函数[start,end)
void sum(long start, long end, long& ans) {long s = 0;for(auto i = start; i < end; i++) {s += i;}ans = s;
}const long S = 100000000;int main() {// 测量一下把工作分摊给两个线程做的时间measure([](){long ans1, ans2;thread t1 = thread(sum, 0, S >> 1, std::ref(ans1));thread t2 = thread(sum, S >> 1, S, std::ref(ans2));t1.join();t2.join();cout << "ans = " << ans1 + ans2 << endl;});// 测量一下单线程工作时间measure([](){long ans;sum(0, S, ans);cout << "ans = " << ans << endl;});return 0;
}

打印结果：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
ans = 887459712
执行了0.13546秒
ans = 887459712
执行了0.240006秒Process finished with exit code 0

当然这里有一个细节：
如果在多线程程序中我们传入了一个ref引用，在线程程序中我们最好不要直接对这个ref值操作，而是采用一个临时变量，例如上面的程序中我们就使用了一个临时变量s，对s进行累加后再把值赋给ans。这样会提高程序运行效率。

case5：future + get 获取并发结果

future包裹线程运行结果，使用方法如下：
由于我们线程函数的结果是long，所以首先定义future<long>

#include <iostream>
#include <thread>
#include <future>
#include <vector>using namespace std;// 测量一个函数的运行时间
template <class T>
void measure(T&& func) {using namespace std::chrono;auto start = system_clock::now();// funcfunc();duration<double> diff = system_clock::now() - start;cout << "执行了" << diff.count() << "秒" << endl;
}// 求和函数[start,end)
long sum(long start, long end) {long s = 0;for(auto i = start; i < end; i++) {s += i;}return s;
}const long S = 100000000;int main() {// 测量一下把工作分摊给 threadNums 个线程做的时间measure([](){const long threadNums = 8;vector<future<long>> vec;vec.reserve(threadNums);for (int i = 0; i < threadNums; i++) {vec.push_back(async(sum, (S / threadNums) * i, (S / threadNums) * (i + 1)));}long ans = 0;// get 阻塞式地拿到并发结果for (int i = 0; i < threadNums; i++) {ans += vec[i].get();}cout << "ans = " << ans << endl;});// 测量一下单线程工作时间measure([](){long ans = sum(0, S);cout << "ans = " << ans << endl;});return 0;
}

运行结果如下：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
ans = 887459712
执行了0.0521455秒
ans = 887459712
执行了0.250044秒Process finished with exit code 0

case6：互斥锁

多个线程访问同一个值并且对其修改，会导致数据竞争。：

#include <iostream>
#include <thread>
#include <future>
#include <vector>using namespace std;
// 测量一个函数的运行时间
template <class T>
void measure(T&& func) {using namespace std::chrono;auto start = system_clock::now();// funcfunc();duration<double> diff = system_clock::now() - start;cout << "执行了" << diff.count() << "秒" << endl;
}std::mutex mtx;
// 求和函数 线程安全的
void sum(long& s) {mtx.lock();for (int i = 0; i < 100000; i++) {s++;}mtx.unlock();
}int main() {// 测量一下把工作分摊给 threadNums 个线程做的时间measure([](){vector<thread> v;long s = 0;for (int i = 0; i < 4; i++) {v.emplace_back(std::thread(sum, std::ref(s)));}for (int i = 0; i < 4; i++) {v[i].join();}cout << "ans " << s << endl;});measure([](){long s = 0;for (int i = 0; i < 4; i++) {sum(s);}cout << "ans " << s << endl;});return 0;
}

测试结果：

C:\Users\LENOVO\CLionProjects\untitled\cmake-build-debug\untitled.exe
ans 400000
执行了0.0141654秒
ans 400000
执行了0.0155926秒Process finished with exit code 0

case7：std::lock_guard 类模板

如果mtx.lock()和mtx.unlock()之间的语句发生了异常，unlock()语句没有机会执行！
这会导致mtx一直处于锁着的状态，其他使用sum函数的线程就会阻塞。
c++库已经提供了std::lock_guard类模板，构造时自动加锁，析构时自动解锁：
将case6的sum函数修改为下面形式即可：

// 求和函数 线程安全的
void sum(long& s) {std:;lock_guard<std::mutex> guard(mtx);// mtx.lock();for (int i = 0; i < 100000; i++) {s++;}// mtx.unlock();
}

如果想自己实现的lock_guard的话也可以：

class mutexLockGuard{
private:std::mutex& mtx;
public:explicit mutexLockGuard(std::mutex& mutex) : mtx(mutex){mtx.lock();}~mutexLockGuard() {mtx.unlock();}
};

笔记参考：
C++多线程快速入门

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

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

相关文章

android:configChanges属性总结

android:configChanges属性总结

原文地址&#xff1a;http://blog.csdn.net/zhaokaiqiang1992/article/details/19921703 android中的组件Activity在manifest.xml文件中可以指定参数android&#xff1a;ConfigChanges&#xff0c;用于捕获手机状态的改变。 在Activity中添加了android:configChanges属性&#…
阅读更多...
eclipse 中修改 M2_REPO的值

eclipse 中修改 M2_REPO的值

从eclipse中增加了maven2的插件之后&#xff0c;maven默认的本地库的路径是${user}/.m2/repository/下&#xff0c;一般windows用户的操作系统都安装在C盘&#xff0c;所以这个目录 下的jar包比较危险。我尝试从myeclipse->preferences->java->build path->classpa…
阅读更多...
C++多线程快速入门（二）共享数据同步以及数据竞争

C++多线程快速入门（二）共享数据同步以及数据竞争

目录std::unique_lock类模板仅调用一次线程局部存储原子变量往期内容回顾std::unique_lock类模板 互斥锁保证了线程间的同步&#xff0c;却将并行操作变成了串行操作&#xff0c;对性能有较大影响&#xff0c;所以我们要尽可能减小锁的区间粒度。 lock_guard只能保证在析构的时…
阅读更多...
DNS安全浅议、域名A记录(ANAME)，MX记录，CNAME记录

DNS安全浅议、域名A记录(ANAME)，MX记录，CNAME记录

相关学习资料 http://baike.baidu.com/link?url77B3BYIuVsB3MpK1nOQXI-JbS-AP5MvREzSnnedU7F9_G8l_Kvbkt_O2gKqFw7vm http://www.rfc-editor.org/rfc/rfc1035.txt http://www.rfc-editor.org/rfc/rfc3596.txt http://www.rfc-editor.org/rfc/rfc2782.txt http://www.rfc-edito…
阅读更多...
ThinkInJava4读书笔记之第一章对象入门

ThinkInJava4读书笔记之第一章对象入门

那句话怎么说来着&#xff0c;原句记不住了好像是出来混的迟早要还的。话说当初学校刚开Java课程&#xff0c;自己没有好好学啊&#xff0c;后来直接做了jsp和servlet&#xff0c;然后学了SSH框架和Extjs、jQuery&#xff0c;接着是mybatis&#xff08;ibatis&#xff09;、fre…
阅读更多...
C++多线程快速入门（三）：生产者消费者模型与条件变量使用

C++多线程快速入门（三）：生产者消费者模型与条件变量使用

互斥锁完成 #include <iostream> #include <deque> #include <thread> #include <mutex>std::deque<int> q; std::mutex mtx;static void produce(int val) {while(val--) {std::unique_lock<std::mutex> guard(mtx);q.push_front(val);m…
阅读更多...
【blade利刃出鞘】一起进入移动端webapp开发吧

【blade利刃出鞘】一起进入移动端webapp开发吧

前言 在移动浪潮袭来的时候&#xff0c;小钗有幸进入框架组做webapp框架开发&#xff0c;过程中遇到了移动端的各种坑&#xff0c;也产生了各种激情&#xff0c;就我们公司的发展历程来说 第一阶段&#xff1a;使用传统方式开发移动站点&#xff0c;少量引入HTML5元素 第二阶段…
阅读更多...
题目理解。。

题目理解。。

有时候一道大水题&#xff0c;因为英文描述可能有点复杂或者其它云云&#xff0c; 就比如那道PRO。。 别先被一道题吓一跳&#xff0c;&#xff0c;&#xff0c; 英文描述看深入一点总归会能解决的&#xff0c;尽可能多的考虑情况。大胆尝试。转载于:https://www.cnblogs.com/c…
阅读更多...
C++多线程快速入门（四）shared_mutex以及读写锁应用

C++多线程快速入门（四）shared_mutex以及读写锁应用

在前面的三讲中我们使用的mutex都是普通的std::mutex&#xff0c;这里介绍一下shared_mutex&#xff0c;版本为C17 std::shared_mutex的底层实现时操作系统提供的读写锁&#xff0c;在读多写少的情况下&#xff0c;该shared_mutex比mutex更加高效。 它提供了常用的四种方法&am…
阅读更多...
Tornado/Python 学习笔记（一）

Tornado/Python 学习笔记（一）

1.源代码下载及安装&#xff1a;http://www.tornadoweb.org/en/stable/ 2.python中xmlrpc库官方文档&#xff1a;https://docs.python.org/3/library/xmlrpc.html?highlightxmlrpc 3.xml介绍与学习&#xff1a;http://www.w3school.com.cn/xml/xml_intro.asp XML 被设计为传输…
阅读更多...
spring-aop-annotation

spring-aop-annotation

1。假设你已经配好依赖注入那一块。此时的bean.xml为 <?xml version"1.0" encoding"UTF-8"?><beans xmlns"http://www.springframework.org/schema/beans"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xmlns:cont…
阅读更多...
c++实现简单线程池代码

c++实现简单线程池代码

目录完整代码TaskPool.cppTaskPool.hmain.cpp完整代码 TaskPool.cpp // // Created by LENOVO on 2021/10/25. //#include "TaskPool.h" #include <functional>std::mutex printMutex;TaskPool::TaskPool() : m_bRunning(false) {}TaskPool::~TaskPool() {re…
阅读更多...
Android静态图片人脸识别的完整demo(附完整源码)

Android静态图片人脸识别的完整demo(附完整源码)

Demo功能&#xff1a;利用android自带的人脸识别进行识别&#xff0c;标记出眼睛和人脸位置。点击按键后进行人脸识别&#xff0c;完毕后显示到imageview上。 第一部分&#xff1a;布局文件activity_main.xml [html] view plaincopyprint?<RelativeLayout xmlns:android&qu…
阅读更多...
图论：最短路径搜索--Dijkstra算法(c代码实现)

图论：最短路径搜索--Dijkstra算法(c代码实现)

最近因为辞职&#xff0c;有不少闲功夫&#xff0c;重温下数据结构&#xff0c;顺便练练手。今天说说最短路径搜索算法中的Dijkstra原理和实现。 一&#xff1a;简介 这个算法用于解决图中单源最短路径问题。所谓单源节点是指给定源节点&#xff0c;求图中其它节点到此源节点的…
阅读更多...
C++多线程快速入门（五）简单线程池设计

C++多线程快速入门（五）简单线程池设计

目录设计思路主线程运行逻辑task以及taskpool设计详细流程讲解完整代码打印结果往期回顾设计思路 线程池实际上就是一组线程&#xff0c;当我们需要异步执行一些任务时&#xff0c;经常要通过OS频繁创建和销毁线程&#xff0c;不如直接创建一组在程序生命周期内不会退出的线程…
阅读更多...
C--函数

C--函数

函数:具有特定功能的代码段,分为库函数,自定义函数. 函数定义: 函数返回值类型 函数名(形式参数列表) { 代码段; return 返回值; } 注意:每个函数返回值最多只有一个.return是一个函数结束的标志. 形式参数(形参):函数定义时使用的虚拟参数名,用以接收函数调用是传递过来的实际…
阅读更多...
公式系统 - TradeBlazer公式基础 - Bar数据

公式系统 - TradeBlazer公式基础 - Bar数据

Bar数据 在介绍Bar数据之前&#xff0c;首先&#xff0c;我们需要讨论一下TradeBlazer公式的计算方法&#xff0c;针对上面介绍的各种公式类型&#xff0c;包含公式应用&#xff0c;在公式进行计算时&#xff0c;都是建立在基本数据源(Bar数据)之上&#xff0c;我们这里所谓的B…
阅读更多...
C++网络编程快速入门（一）：TCP网络通信基本流程以及基础函数使用

C++网络编程快速入门（一）：TCP网络通信基本流程以及基础函数使用

目录流程概述服务器端代码实现客户端代码实现函数和结构讲解sockaddr_in和sockaddrsocket &#xff1a; 创建一个socket连接bind &#xff1a;绑定地址以及端口号问题流程概述 客户端与服务器之间的网络通信基本原理如下所示&#xff0c;复杂一点的架构可能会添加消息中间件。…
阅读更多...
php 字符串处理

php 字符串处理

addcslashes — 为字符串里面的部分字符添加反斜线转义字符addslashes — 用指定的方式对字符串里面的字符进行转义bin2hex — 将二进制数据转换成十六进制表示chop — rtrim() 的别名函数chr — 返回一个字符的ASCII码chunk_split — 按一定的字符长度将字符串分割成小块conve…
阅读更多...
使用前端框架Foundation 4来帮助简化响应式设计开发

使用前端框架Foundation 4来帮助简化响应式设计开发

日期&#xff1a;2013-3-12 来源&#xff1a;GBin1.com Foundation是一套使用广泛的前端开发套件&#xff0c;可以帮助你快速的网站。最近ZURB发布了一个新版本的Foundation 4前端框架&#xff0c;能够有效的帮助你快速的开发响应式的网站。 和另外一个套知名的前端框架BootSt…
阅读更多...
最新文章

Copyright @ 2022~2023