深入探讨多线程编程:从0-1为您解释多线程(下)

文章目录

  • 6. 死锁
    • 6.1 死锁
      • 原因
    • 6.2 避免死锁的方法
      • 加锁顺序一致性。
      • 超时机制。
      • 死锁检测和解除机制。

6. 死锁

6.1 死锁

原因

  1. 系统资源的竞争:(产生环路)当系统中供多个进程共享的资源数量不足以满足进程的需要时,会引起进程对2资源的竞争而产生死锁。例如,两个进程分别持有资源R1和R2,但进程1申请资源R2,进程2申请资源R1时,两者都会因为所需资源被占用而阻塞。
#include <iostream>
#include <thread>
#include <mutex>
#include <chrono>std::timed_mutex resourceR1, resourceR2;bool acquireResource(std::timed_mutex& r, const std::string& name) {std::chrono::milliseconds timeout(5000);  // 5秒超时if (r.try_lock_for(timeout)) {std::cout << "Process " << name << " has acquired its resource." << std::endl;return true;}else {std::cout << "Process " << name << " failed to acquire the resource within 5 seconds. Terminating..." << std::endl;return false;}
}void process1() {if (acquireResource(resourceR1, "1")) {// 如果成功获取资源R1,尝试获取资源R2if (!acquireResource(resourceR2, "1")) {// 若获取资源R2失败,解锁资源R1并终止线程resourceR1.unlock();return;}/********************************************************///需要执行的业务逻辑(不会被执行)/********************************************************/resourceR1.unlock();resourceR2.unlock();}
}void process2() {if (acquireResource(resourceR2, "2")) {if (!acquireResource(resourceR1, "2")) {resourceR2.unlock();return;}// 同样,此处的业务逻辑也不会被执行resourceR1.unlock();resourceR2.unlock();}
}int main() {std::thread t1(process1);std::thread t2(process2);t1.join();t2.join();return 0;
}

在这里插入图片描述
在这里插入图片描述

  1. 逻辑错误:程序逻辑错误可能导致死锁,如死循环或无限等待的情况。例如,在数据交换中,如果一方发送的消息丢失,发送方会等待接收返回信息,而接收方会无限等待接收信息,导致死锁。
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <chrono>std::mutex mtx;
std::condition_variable cv1, cv2;
bool messageReceived = false;
bool acknowledgmentSent = false;// 发送线程
void senderThread() {std::cout << "Sender: Sending data...\n";// 假设发送数据(此处省略具体发送逻辑)std::unique_lock<std::mutex> lk(mtx);auto timeout = std::chrono::system_clock::now() + std::chrono::seconds(5);while (!acknowledgmentSent && std::cv_status::timeout == cv1.wait_until(lk, timeout)) {if (std::chrono::system_clock::now() >= timeout) {std::cout << "Sender: Timeout occurred, assuming no acknowledgement received and exiting.\n";break;  // 超时后退出循环,不再等待确认}}lk.unlock();
}// 接收线程
void receiverThread() {std::this_thread::sleep_for(std::chrono::seconds(2)); // 假设在此期间消息丢失std::unique_lock<std::mutex> lk(mtx);std::cout << "Receiver: Received data...\n";messageReceived = true;cv2.notify_one();  // 假设这是接收方发送确认的方式// 接收方也会等待发送方确认收到确认信息(这是一个逻辑错误,实际应用中通常不需要)auto timeout = std::chrono::system_clock::now() + std::chrono::seconds(5);while (!messageReceived && std::cv_status::timeout == cv2.wait_until(lk, timeout)) {if (std::chrono::system_clock::now() >= timeout) {std::cout << "Receiver: Timeout occurred, assuming message not delivered and exiting.\n";break;  // 超时后退出循环,不再等待消息}}lk.unlock();
}int main() {std::thread t1(senderThread);std::thread t2(receiverThread);t1.join();t2.join();return 0;
}

在这里插入图片描述
两秒后
在这里插入图片描述
五秒后
在这里插入图片描述

  1. 不恰当的同步:在并发编程中,不恰当的同步机制可能导致死锁。例如,多个线程在等待其他线程释放锁时,如果这些线程彼此都持有对方需要的锁,就会导致死锁。
#include <iostream>
#include <thread>
#include <mutex>
#include <chrono>std::timed_mutex mtx1, mtx2;void threadFunction1() {if (mtx1.try_lock_for(std::chrono::seconds(5))) {std::cout << "Thread 1: Acquired mtx1\n";// 尝试获取mtx2,如果5秒内未获取成功,则释放mtx1以防止死锁if (!mtx2.try_lock_for(std::chrono::seconds(5))) {mtx1.unlock();std::cout << "Thread 1: Could not acquire mtx2 within 5 seconds, releasing mtx1 to prevent deadlock.\n";return;}std::cout << "Thread 1: Acquired mtx2\n";mtx2.unlock();mtx1.unlock();}else {std::cout << "Thread 1: Could not acquire mtx1 within 5 seconds.\n";}
}void threadFunction2() {if (mtx2.try_lock_for(std::chrono::seconds(5))) {std::cout << "Thread 2: Acquired mtx2\n";if (!mtx1.try_lock_for(std::chrono::seconds(5))) {mtx2.unlock();std::cout << "Thread 2: Could not acquire mtx1 within 5 seconds, releasing mtx2 to prevent deadlock.\n";return;}std::cout << "Thread 2: Acquired mtx1\n";mtx1.unlock();mtx2.unlock();}else {std::cout << "Thread 2: Could not acquire mtx2 within 5 seconds.\n";}
}int main() {std::thread t1(threadFunction1);std::thread t2(threadFunction2);t1.join();t2.join();return 0;
}

在这里插入图片描述
在这里插入图片描述

6.2 避免死锁的方法

加锁顺序一致性。

#include <iostream>
#include <thread>
#include <mutex>std::mutex mtx1, mtx2;// 定义一个固定的全局锁顺序
const bool lockOrder[] = {true, false}; // 先锁mtx1,后锁mtx2void worker(int id) {if (lockOrder[0]) {mtx1.lock();std::cout << "Thread " << id << ": Acquired mtx1\n";// 在拥有mtx1的情况下尝试获取mtx2mtx2.lock();std::cout << "Thread " << id << ": Acquired mtx2\n";} else {// 如果定义的顺序是先锁mtx2mtx2.lock();std::cout << "Thread " << id << ": Acquired mtx2\n";// 在拥有mtx2的情况下尝试获取mtx1mtx1.lock();std::cout << "Thread " << id << ": Acquired mtx1\n";}// 重要:解锁按照相反的顺序进行mtx2.unlock();mtx1.unlock();// 业务逻辑...
}int main() {std::thread t1(worker, 1);std::thread t2(worker, 2);t1.join();t2.join();return 0;
}

在上述示例中,我们预定义了一个全局的锁获取顺序数组lockOrder,确保所有线程按照同样的顺序(本例中是先获取mtx1再获取mtx2)来获取互斥锁。这样可以防止如下情况:一个线程持有mtx1并等待mtx2,而另一个线程持有mtx2并等待mtx1,从而形成死锁。

请注意,为了避免死锁,不仅在获取锁时需遵循一致的顺序,而且在解锁时也应按照相反的顺序进行。在上面的代码中,无论哪种顺序,我们都是先解锁mtx2,然后再解锁mtx1。这样可以确保在任何时候,已经持有两个锁的线程都能顺利地按顺序释放它们,避免死锁的发生。

超时机制。

以下是一个使用std::timed_mutex的示例,当尝试获取互斥锁时设置一个超时时间,如果在规定时间内没能获取到锁,则线程放弃获取,从而可以避免死锁的发生:

#include <iostream>
#include <thread>
#include <mutex>
#include <chrono>std::timed_mutex mtx1, mtx2;void worker(int id) {if (id == 1) {// 线程1尝试获取mtx1if (mtx1.try_lock_for(std::chrono::seconds(5))) {std::cout << "Thread " << id << ": Acquired mtx1\n";// 在持有mtx1的前提下尝试获取mtx2,超时时间为5秒if (mtx2.try_lock_for(std::chrono::seconds(5))) {std::cout << "Thread " << id << ": Acquired mtx2\n";mtx2.unlock();} else {std::cout << "Thread " << id << ": Could not acquire mtx2 within 5 seconds, releasing mtx1.\n";}mtx1.unlock();} else {std::cout << "Thread " << id << ": Could not acquire mtx1 within 5 seconds.\n";}} else if (id == 2) {// 线程2尝试获取mtx2,同样设置5秒超时if (mtx2.try_lock_for(std::chrono::seconds(5))) {std::cout << "Thread " << id << ": Acquired mtx2\n";// 在持有mtx2的前提下尝试获取mtx1,同样设置5秒超时if (mtx1.try_lock_for(std::chrono::seconds(5))) {std::cout << "Thread " << id << ": Acquired mtx1\n";mtx1.unlock();} else {std::cout << "Thread " << id << ": Could not acquire mtx1 within 5 seconds, releasing mtx2.\n";}mtx2.unlock();} else {std::cout << "Thread " << id << ": Could not acquire mtx2 within 5 seconds.\n";}}
}int main() {std::thread t1(worker, 1);std::thread t2(worker, 2);t1.join();t2.join();return 0;
}

在这个示例中,两个线程都试图按顺序获取互斥锁,但是如果在5秒钟内无法获取所需的下一个锁,它们都会释放已经持有的锁并退出相应的操作,从而避免了死锁的发生。

死锁检测和解除机制。

在C++标准库中并没有内置的死锁检测和解除机制,但我们可以通过设计良好的程序逻辑和利用特定的同步原语(如条件变量、互斥量等)来实施自己的死锁检测和解除策略。

// 假设有以下结构表示资源和进程的状态
struct Process {int pid; // 进程IDstd::vector<int> holdingResources; // 当前持有的资源ID集合std::vector<int> requestingResources; // 正在请求的资源ID集合
};struct Resource {int rid; // 资源IDint available; // 当前可用的数量std::map<int, int> allocated; // 已分配给各个进程的资源数量
};// 假设有个全局的数据结构存储所有进程和资源的状态
std::vector<Process> processes;
std::vector<Resource> resources;// 自定义的死锁检测函数(伪代码)
bool detectAndResolveDeadlocks() {// 初始化资源分配图(Resource Allocation Graph, RAG)// ...// 检查是否有循环等待for (auto& p : processes) {// 使用拓扑排序或其他方法检查是否存在环路if (isCycleDetectedInRAG(p)) {// 死锁检测出环,现在需要解除死锁resolveDeadlock(p.pid);return true;}}return false; // 没有发现死锁
}// 解除死锁的策略有很多种,以下是一个简化的版本(仅作示例)
void resolveDeadlock(int pid) {// 可以选择一个进程撤销其部分请求或者抢占它的资源// 例如,选择持有最多资源但请求未满足最多的进程,释放其最少的一个资源Process& victim = getVictimProcess(pid);int resourceToRelease = getResourceToRelease(victim);// 释放资源并重新开始检测releaseResource(victim, resourceToRelease);victim.requestingResources.erase(std::find(victim.requestingResources.begin(), victim.requestingResources.end(), resourceToRelease));
}// ... 其他辅助函数(getVictimProcess, getResourceToRelease, releaseResource等)

在实践中,死锁检测和解除往往涉及到复杂的算法和策略,比如银行家算法等。在C++程序中实现这样的功能通常需要自定义数据结构和算法,并且考虑到并发环境下的安全性,还需要适当使用锁来保护共享数据。

由于C++标准库提供的互斥量和条件变量等工具不具备自动死锁检测和解除功能,开发者需要自行设计和实现适合项目需求的死锁预防、检测及解除方案。在某些高级并发库中,可能提供了更高级别的抽象帮助处理这类问题,但C++标准库本身不直接提供这样的机制。

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

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

相关文章

今日早报 每日精选15条新闻简报 每天一分钟 知晓天下事 3月29日,星期五

每天一分钟&#xff0c;知晓天下事&#xff01; 2024年3月29日 星期五 农历二月二十 1、 网络表演&#xff08;直播与短视频&#xff09;运营团体标准发布&#xff1a;应建立举报处置机制。 2、 商务部&#xff1a;中国决定终止对澳大利亚进口葡萄酒征收反倾销税和反补贴税。…

编程语言|C语言——数组与指针

一、数组 同一类型的变量——元素&#xff08;element&#xff09;集中在一起&#xff0c;在内存上排列成一条直线&#xff0c;这就是数组&#xff08;array&#xff09;。 1.1 一维数组 一维数组的声明 int arr1[10]; int arr2[2 8];#define N 10 int arr3[N];int count 10;…

深度学习 - PyTorch基本流程 (代码)

直接上代码 import torch import matplotlib.pyplot as plt from torch import nn# 创建data print("**** Create Data ****") weight 0.3 bias 0.9 X torch.arange(0,1,0.01).unsqueeze(dim 1) y weight * X bias print(f"Number of X samples: {len(…

蓝桥杯2016年第十三届省赛真题-生日蜡烛

一、题目 生日蜡烛. 某君从某年开始每年都举办一次生日party&#xff0c;并且每次都要吹熄与年龄相同根数的蜡烛。 现在算起来&#xff0c;他一共吹熄了236根蜡烛。 请问&#xff0c;他从多少岁开始过生日party的&#xff1f; 请填写他开始过生日party的年龄数。 注意&#xff…

python笔记(6)String(字符串)

目录 访问字符串中的值 Python字符串运算符 Python 字符串格式化 str.format() 数字格式化 多行注释 f-string Unicode 字符串 Python 的字符串内建函数 我们可以用单引号或者双引号"来创建字符串。 创建字符串很简单&#xff0c;给变量分配一个值即可例如 ahell…

基于资源的约束委派(下)

webclient http self relay Web 分布式创作和版本控制 (WebDAV) 是超文本传输协议 (HTTP) 的扩展&#xff0c;它定义了如何使用 HTTP ( docs.microsoft.com )执行复 制、移动、删除和创建等基本文件功能 需要启用 WebClient 服务才能使基于 WebDAV 的程序和功能正常工作。事实…

全国中学基础信息 API 数据接口

全国中学基础信息 API 数据接口 基础数据&#xff0c;高校高考&#xff0c;提供全国初级高级中学基础数据&#xff0c;定时更新&#xff0c;多维度筛选。 1. 产品功能 2024 年数据已更新&#xff1b;提供最新全国中学学校基本信息&#xff1b;包含全国初级中学与高等中学&…

Rust机器学习框架Candle

一、概述 Candle 是由知名开源组织 Hugging Face 开发的一个极简的机器学习框架。它专为 Rust 语言打造&#xff0c;致力于提供高性能和易用性的完美结合。Candle 的诞生为 Rust 生态在机器学习领域带来了新的选择&#xff0c;让 Rust 开发者能够更轻松地构建和部署机器学习应…

家庭琐事对工作效率的影响及应对策略

在快节奏的现代生活中&#xff0c;工作与家庭生活之间的界限日益模糊&#xff0c;人们往往难以将两者完全割裂开来。有时候&#xff0c;我们正在全身心投入工作时&#xff0c;却可能被突如其来的家庭琐事打扰&#xff0c;这不仅影响了心情&#xff0c;更会波及到工作效率和质量…

silk-v3-decoder将sil转为mp3

一、新建临时目录 新建临时目录&#xff0c;可自定义&#xff0c;本次新建目录为 /opt/packages mkdir /opt/packages二、下载、安装lame # cd /opt/packages# wget http://downloads.sourceforge.net/lame/lame-3.100.tar.gz# tar -zxvf lame-3.100.tar.gz# cd lame-3.100#…

git之目前的主流版本

官方文档 简介 我们都知道&#xff0c;在开发过程中&#xff0c;版本控制是至关重要的。Git作为目前最为流行的版本控制系统&#xff0c;已经成为了开发者们的标配。出于好奇&#xff0c;本人对git目前主流几大版本&#xff08;GitLab、GitHub、Gitee 和 GitCode&#xff09;…

虚拟现实(VR)项目的开发工具

虚拟现实&#xff08;VR&#xff09;项目的开发涉及到多种工具&#xff0c;这些工具可以帮助开发者从建模、编程到最终内容的发布。以下是一些被广泛认可的VR开发工具&#xff0c;它们覆盖了从3D建模到交互设计等多个方面。北京木奇移动技术有限公司&#xff0c;专业的软件外包…

取消svn关联脚本

写在前面&#xff0c;该脚本由朋友提供&#xff0c;来源与网络&#xff0c;侵删。 取消svn关联脚本 创建一个文件&#xff0c;后缀名为reg&#xff0c;将下面的脚本复制到文件里。 Windows Registry Editor Version 5.00 [HKEY_LOCAL_MACHINE\SOFTWARE\Classes\Folder\shel…

spring boot中使用spring cache

原因 项目原来越慢&#xff0c;为了提升效率加入spring cache 初步想法把数据库的压力减轻一点。 引入 pom 中加入&#xff1a; <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-cache</artifactId&g…

机器学习_集成学习_梯度提升_回归_决策树_XGBoost相关概念

目录 1. 机器学习 使用监督吗&#xff1f;什么又是监督学习&#xff1f; 2. 与XGBoost 类似的机器学习方法有哪些&#xff1f; 3. 随机森林方法 和 梯度提升方法 有什么区别&#xff1f; 分别应用于什么场景&#xff1f; 4. 决策树回归方法 和 Gradient Boosting类回归方法…

为什么我的微信小程序 窗口背景色backgroundColor设置参数 无效的问题处理记录!

当我们在微信小程序 json 中设置 backgroundColor 时&#xff0c;实际在电脑的模拟器中根本看不到效果。 这是因为 backgroundColor 指的窗体背景颜色&#xff0c;而不是页面的背景颜色&#xff0c;即窗体下拉刷新或上拉加载时露出的背景。在电脑的模拟器中是看不到这个动作的…

发挥ChatGPT潜力:高效撰写学术论文技巧

ChatGPT无限次数:点击直达 发挥ChatGPT潜力&#xff1a;高效撰写学术论文技巧 在当今信息爆炸的时代&#xff0c;如何高效撰写学术论文成为许多研究者关注的焦点。而随着人工智能技术的不断发展&#xff0c;如何利用ChatGPT这一先进的技术工具来提升论文写作效率&#xff0c;成…

Elasticsearch 面试题及参考答案:深入解析与实战应用

在大数据时代,Elasticsearch 以其强大的搜索能力和高效的数据处理性能,成为了数据架构师和开发者必备的技能之一。本文将为您提供一系列精选的 Elasticsearch 面试题及参考答案,帮助您在面试中脱颖而出,同时也为您的大数据架构设计提供实战参考。 目录 1. 为什么要使用 E…

Acwing_795前缀和 【一维前缀和】+【模板】二维前缀和

Acwing_795前缀和 【一维前缀和】 题目&#xff1a; 代码&#xff1a; #include <bits/stdc.h> #define int long long #define INF 0X3f3f3f3f #define endl \n using namespace std; const int N 100010; int arr[N];int n,m; int l,r; signed main(){std::ios::s…

Flink基于Hudi维表Join缺陷解析及解决方案

Hudi&#xff0c;这个近年来备受瞩目的数据存储解决方案&#xff0c;无疑是大数据领域的一颗耀眼新星。其凭借出色的性能和稳定性&#xff0c;以及对于数据湖场景的深度适配&#xff0c;赢得了众多企业和开发者的青睐。然而&#xff0c;正如任何一项新兴技术&#xff0c;Hudi在…