时间:2021-05-20
在做多线程编程时,有两个场景我们都会遇到:
今天我用一个简单的例子来给大家介绍下锁和条件变量的使用。
代码使用C++11
示例代码
#include <iostream>#include <mutex>#include <thread>#include <condition_variable>std::mutex g_mutex; // 用到的全局锁std::condition_variable g_cond; // 用到的条件变量int g_i = 0;bool g_running = true;void ThreadFunc(int n) { // 线程执行函数 for (int i = 0; i < n; ++i) { { std::lock_guard<std::mutex> lock(g_mutex); // 加锁,离开{}作用域后锁释放 ++g_i; std::cout << "plus g_i by func thread " << std::this_thread::get_id() << std::endl; } } std::unique_lock<std::mutex> lock(g_mutex); // 加锁 while (g_running) { std::cout << "wait for exit" << std::endl; g_cond.wait(lock); // wait调用后,会先释放锁,之后进入等待状态;当其它进程调用通知激活后,会再次加锁 } std::cout << "func thread exit" << std::endl;}int main() { int n = 100; std::thread t1(ThreadFunc, n); // 创建t1线程(func thread),t1会执行`ThreadFunc`中的指令 for (int i = 0; i < n; ++i) { { std::lock_guard<std::mutex> lock(g_mutex); ++g_i; std::cout << "plus g_i by main thread " << std::this_thread::get_id() << std::endl; } } { std::lock_guard<std::mutex> lock(g_mutex); g_running = false; g_cond.notify_one(); // 通知其它线程 } t1.join(); // 等待线程t1结束 std::cout << "g_i = " << g_i << std::endl;}程序运行后,关键输出如下:
plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744plus g_i by func thread 139921006847744wait for exit // func thread等待main thread发来的退出信号plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816plus g_i by main thread 139921025066816func thread exitg_i = 200 // 锁机制保证了g_i的正确可以看到:
std::this_thread::get_id()g_i加锁方法介绍
加锁相关的代码为:
{ std::lock_guard<std::mutex> lock(g_mutex); ......}要点为:
这样就实现了加锁和解锁的过程,为什么不直接调用加锁解锁方法呢?
我想,这是因为如果加锁和解锁中间的代码出现了问题,导致线程函数异常退出,那么这个锁就一直无法得到释放,其它线程处理的不好的话,就会造成死锁了。
条件变量使用介绍
结束语
以上所述是小编给大家介绍的C++多线程中的锁和条件变量使用教程,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
条件变量是线程之前同步的另一种机制。条件变量给多线程提供了一种会和的场所。当条件变量和互斥锁一起使用时,允许线程以无竞争的方式等待特定的条件发生。这样大大减少了
本文研究的主要是python使用锁访问共享变量,具体介绍和实现如下。python做多线程编程时,多个线程若同时访问某个变量,可能会对变量数据造成破坏,pyhon
使用C++11标准的的线程语法,用两个线程轮流打印整数,一个线程打印奇数,一个线程打印偶数。可以练习线程的基本操作、线程锁和条件变量等技术。完整代码如下。代码后
在C++11以前,C++的多线程编程均需依赖系统或第三方接口实现,一定程度上影响了代码的移植性。C++11中,引入了boost库中的多线程部分内容,形成C++标
CAS算法(compareandswap)CAS算法是一种有名的无锁算法。无锁编程,即不使用锁的情况下实现多线程之间的变量同步,也就是在没有线程被阻塞的情况下实