【CPP】多线程并发—— Mutex 和 Lock

2024-05-13 22:28
文章标签 并发 多线程 lock cpp mutex

本文主要是介绍【CPP】多线程并发—— Mutex 和 Lock,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

#include <iostream>  
#include <thread>  
#include <mutex>  
#include "my_utils.h"std::mutex mtx; // 全局互斥锁  
int shared_data = 0; // 共享数据  void increment() {  for (int i = 0; i < 10; ++i) {  std::cout <<"increment lock_guard: "<<"\n";std::lock_guard<std::mutex> lock(mtx); // 在这里锁定互斥锁  ++shared_data;  std::cout <<"increment: "<<shared_data<<"\n";SLEEP_FOR_500_MS();}  SLEEP_FOR_500_MS();for (int i = 0; i < 10; ++i) {  std::cout <<"increment lock_guard: "<<"\n";std::lock_guard<std::mutex> lock(mtx); // 在这里锁定互斥锁  ++shared_data;  std::cout <<"increment: "<<shared_data<<"\n";SLEEP_FOR_500_MS();}  
}  void decrement() {  for (int i = 0; i < 10; ++i) {  std::cout <<"decrement lock_guard1: "<<"\n";std::lock_guard<std::mutex> lock(mtx); // 在这里锁定互斥锁  --shared_data;  SLEEP_FOR_500_MS();std::cout <<"decrement: "<<shared_data<<"\n";}  for (int i = 0; i < 10; ++i) {  std::cout <<"decrement lock_guard2: "<<"\n";std::lock_guard<std::mutex> lock(mtx); // 在这里锁定互斥锁  --shared_data;  SLEEP_FOR_500_MS();std::cout <<"decrement: "<<shared_data<<"\n";}  
}  int main() {  std::thread t1(increment);  std::thread t2(decrement);  std::cout << "task inited: " << shared_data << std::endl;  t1.join();  t2.join();  std::cout << "Final value of shared_data: " << shared_data << std::endl;  return 0;  
}

运行结果如下:


increment lock_guard: 
increment: 1
task inited: 1
decrement lock_guard1: 
increment lock_guard: 
increment: 2
increment lock_guard: 
decrement: 1
decrement lock_guard1: 
decrement: 0
decrement lock_guard1: 
decrement: -1
decrement lock_guard1: 
decrement: -2
decrement lock_guard1: 
decrement: -3
decrement lock_guard1: 
decrement: -4
decrement lock_guard1: 
decrement: -5
decrement lock_guard1: 
decrement: -6
decrement lock_guard1: 
decrement: -7
decrement lock_guard1: 
decrement: -8
decrement lock_guard2: 
decrement: -9
decrement lock_guard2: 
decrement: -10
decrement lock_guard2: 
decrement: -11
decrement lock_guard2: 
decrement: -12
decrement lock_guard2: 
decrement: -13
decrement lock_guard2: 
decrement: -14
decrement lock_guard2: 
decrement: -15
decrement lock_guard2: 
decrement: -16
decrement lock_guard2: 
decrement: -17
decrement lock_guard2: 
decrement: -18
increment: -17
increment lock_guard: 
increment: -16
increment lock_guard: 
increment: -15
increment lock_guard: 
increment: -14
increment lock_guard: 
increment: -13
increment lock_guard: 
increment: -12
increment lock_guard: 
increment: -11
increment lock_guard: 
increment: -10
increment lock_guard: 
increment: -9
increment lock_guard: 
increment: -8
increment lock_guard: 
increment: -7
increment lock_guard: 
increment: -6
increment lock_guard: 
increment: -5
increment lock_guard: 
increment: -4
increment lock_guard: 
increment: -3
increment lock_guard: 
increment: -2
increment lock_guard: 
increment: -1
increment lock_guard: 
increment: 0
Final value of shared_data: 0

这篇关于【CPP】多线程并发—— Mutex 和 Lock的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/987001

相关文章

SpringBoot中使用 ThreadLocal 进行多线程上下文管理及注意事项小结

《SpringBoot中使用ThreadLocal进行多线程上下文管理及注意事项小结》本文详细介绍了ThreadLocal的原理、使用场景和示例代码,并在SpringBoot中使用ThreadLo... 目录前言技术积累1.什么是 ThreadLocal2. ThreadLocal 的原理2.1 线程隔离2

Java多线程父线程向子线程传值问题及解决

《Java多线程父线程向子线程传值问题及解决》文章总结了5种解决父子之间数据传递困扰的解决方案,包括ThreadLocal+TaskDecorator、UserUtils、CustomTaskDeco... 目录1 背景2 ThreadLocal+TaskDecorator3 RequestContextH

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁(Deadlock)是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁?死锁的典型条件:2. 导致死锁的常见原因2.1 锁的顺序问题错误示例:不同

浅析Rust多线程中如何安全的使用变量

《浅析Rust多线程中如何安全的使用变量》这篇文章主要为大家详细介绍了Rust如何在线程的闭包中安全的使用变量,包括共享变量和修改变量,文中的示例代码讲解详细,有需要的小伙伴可以参考下... 目录1. 向线程传递变量2. 多线程共享变量引用3. 多线程中修改变量4. 总结在Rust语言中,一个既引人入胜又可

高并发环境中保持幂等性

在高并发环境中保持幂等性是一项重要的挑战。幂等性指的是无论操作执行多少次,其效果都是相同的。确保操作的幂等性可以避免重复执行带来的副作用。以下是一些保持幂等性的常用方法: 唯一标识符: 请求唯一标识:在每次请求中引入唯一标识符(如 UUID 或者生成的唯一 ID),在处理请求时,系统可以检查这个标识符是否已经处理过,如果是,则忽略重复请求。幂等键(Idempotency Key):客户端在每次

多线程解析报表

假如有这样一个需求,当我们需要解析一个Excel里多个sheet的数据时,可以考虑使用多线程,每个线程解析一个sheet里的数据,等到所有的sheet都解析完之后,程序需要提示解析完成。 Way1 join import java.time.LocalTime;public class Main {public static void main(String[] args) thro

Java并发编程之——BlockingQueue(队列)

一、什么是BlockingQueue BlockingQueue即阻塞队列,从阻塞这个词可以看出,在某些情况下对阻塞队列的访问可能会造成阻塞。被阻塞的情况主要有如下两种: 1. 当队列满了的时候进行入队列操作2. 当队列空了的时候进行出队列操作123 因此,当一个线程试图对一个已经满了的队列进行入队列操作时,它将会被阻塞,除非有另一个线程做了出队列操作;同样,当一个线程试图对一个空

Java 多线程概述

多线程技术概述   1.线程与进程 进程:内存中运行的应用程序,每个进程都拥有一个独立的内存空间。线程:是进程中的一个执行路径,共享一个内存空间,线程之间可以自由切换、并发执行,一个进程最少有一个线程,线程实际数是在进程基础之上的进一步划分,一个进程启动之后,进程之中的若干执行路径又可以划分成若干个线程 2.线程的调度 分时调度:所有线程轮流使用CPU的使用权,平均分配时间抢占式调度

Java 多线程的基本方式

Java 多线程的基本方式 基础实现两种方式: 通过实现Callable 接口方式(可得到返回值):

java线程深度解析(五)——并发模型(生产者-消费者)

http://blog.csdn.net/Daybreak1209/article/details/51378055 三、生产者-消费者模式     在经典的多线程模式中,生产者-消费者为多线程间协作提供了良好的解决方案。基本原理是两类线程,即若干个生产者和若干个消费者,生产者负责提交用户请求任务(到内存缓冲区),消费者线程负责处理任务(从内存缓冲区中取任务进行处理),两类线程之