- VisualStudio2022插件的安装及使用-编程手把手系列文章
- pprof-在现网场景怎么用
- C#实现的下拉多选框,下拉多选树,多级节点
- 【学习笔记】基础数据结构:猫树
在多线程编程中,死锁是一种非常常见的问题,稍不留神可能就会产生死锁,今天就和大家分享死锁产生的原因,如何排查,以及解决办法.
线程死锁通常是因为两个或两个以上线程在资源争夺中,形成循环等待,导致它们都无法继续执行各自后续操作的现象.
我们结合下图简单举个例子,线程1拥有资源A同时使用锁A进行锁定,并等待获取资源B;与此同时线程2拥有资源B同时使用锁B进行锁定,并等待获取资源A。此时便形成了线程1和线程2相互等待对方先释放锁的现象,形成了死循环,最终导致死锁.
根据死锁产生的原因,可以总结出以下四个死锁产生的必要条件.
互斥即非此即彼,一个资源要不是我拥有,要不是你拥有,就是不能我们俩同时拥有。也就是互斥条件是指至少有一个资源处于非共享状态,一次只能有一个线程可以访问该资源.
该条件是指一个线程在拥有至少一个资源的同时还在等待获取其他线程拥有的资源.
该条件是指一个线程一旦获取了某个资源,则不可被强行剥夺对该资源的所有权,只能等待该线程自己主动释放.
循环等待是指线程等待资源形成的循环链,比如线程A等待资源B,线程B等待资源C,线程C等待资源A,但是资源A被线程A拥有,资源B被线程B拥有,资源C被线程C拥有,如此形成了依赖死循环,都在等待其他线程释放资源.
下面我们实现一个简单的死锁代码示例,代码如下:
//锁1
private static readonly object lock1 = new();
//锁2
private static readonly object lock2 = new();
//模拟两个线程死锁
public static void ThreadDeadLock()
{
//线程1
var thread1 = new Thread(Thread1);
//线程2
var thread2 = new Thread(Thread2);
//线程1 启动
thread1.Start();
//线程2 启动
thread2.Start();
//等待 线程1 执行完毕
thread1.Join();
//等待 线程2 执行完毕
thread2.Join();
}
//线程1
public static void Thread1()
{
//线程1 首先获取 锁1
lock (lock1)
{
Console.WriteLine("线程1: 已获取 锁1");
//模拟一些操作
Thread.Sleep(1000);
Console.WriteLine("线程1: 等待获取 锁2");
//线程1 等待 锁2
lock (lock2)
{
Console.WriteLine("线程1: 已获取 锁2");
}
}
}
//线程2
public static void Thread2()
{
//线程2 首先获取 锁2
lock (lock2)
{
Console.WriteLine("线程2: 已获取 锁2");
//模拟一些操作
Thread.Sleep(1000);
Console.WriteLine("线程2: 等待获取 锁1");
//线程2 等待 锁1
lock (lock1)
{
Console.WriteLine("线程2: 已获取 锁1");
}
}
}
在上面的代码中,thread1 先拥有lock1,然后尝试获取lock2;thread2 先拥有锁住 lock2,然后尝试获取lock1;由于线程间相互等待对方释放资源,所以导致死锁.
下面我们看看上面代码执行效果:
可以发现线程1和线程2都在等待彼此所拥有的锁.
上一节中我们编写了一个简单的死锁代码示例,但是实际研发过程中代码不可能这么简单直观,一眼就能看出来问题所在。因此如何排查发生死锁呢?
其实我们的开发工具Visual Studio就可以查看。可以通过调试菜单中窗口下的线程、调用堆栈、并行堆栈等调试窗口查看.
上面代码正常运行后,编辑器为如下状态,也没有报错,啥也看不出来.
在默认状态下是无法看出东西,此时我们只需要点击全部中断按钮,则死锁的相关信息都会展示出来,如下图.
可以看到已经提示检测到死锁了,同时在调用堆栈窗口中还可以通过双击切换具体发生死锁的代码.
我们再切换至并行堆栈调试窗口,和调用堆栈相比,并行堆栈窗口更偏向图形化,并且发生死锁的两个线程方法都有体现出来,同样可以通过双击切换到具体代码,如下图:
下面我们再来看看线程调试窗口,如下图,可以发现前面有两个箭头,其中黄色箭头表示当前选中的发生死锁的代码,图中绿色选中代码,灰色箭头表示第一个发生死锁的代码。可以通过双击当前窗口中行进行发生死锁代码的切换,如下图:
当然还可以通过其他方式排查死锁,比如分析dump文件,这里就不深入了,后面有机会再单独讲解.
下面介绍几种避免死锁的指导思想.
顺序加锁就是为了避免产生循环等待,如果大家都是先锁定lock1,再锁定lock2,则就不会产生循环等待.
看看如下代码:
//线程1
public static void Thread1New()
{
//线程1 首先获取 锁1
lock (lock1)
{
Console.WriteLine("线程1: 已获取 锁1");
//模拟一些操作
Thread.Sleep(1000);
Console.WriteLine("线程1: 等待获取 锁2");
//线程1 等待 锁2
lock (lock2)
{
Console.WriteLine("线程1: 已获取 锁2");
}
}
}
//线程2
public static void Thread2New()
{
//线程2 首先获取 锁2
lock (lock1)
{
Console.WriteLine("线程2: 已获取 锁2");
//模拟一些操作
Thread.Sleep(1000);
Console.WriteLine("线程2: 等待获取 锁1");
//线程2 等待 锁1
lock (lock2)
{
Console.WriteLine("线程2: 已获取 锁1");
}
}
}
我们看看代码执行结果.
我们可以使用一些其他锁机制,比如使用Monitor.TryEnter方法尝试获取锁,如果在指定时间内没有获取到锁,则释放当前所拥有的锁,以此来避免死锁.
我们可以通过Thead结合CancellationToken实现超时机制,避免线程无限等待。当然可以直接使用Task,因为Task本身就支持CancellationToken,提供了内置的取消支持使用起来更方便.
一个线程在拥有一个锁的同时尽量避免再去申请另一个锁,这样可以避免循环等待.
上面是使用Thread实现的示例,现在大家直接使用Thread可能比较少,大多数都是使用Task,最后给大家一个Task死锁示例,代码如下:
//锁1
private static readonly object lock1 = new();
//锁2
private static readonly object lock2 = new();
//模拟两个任务死锁
public static async Task TaskDeadLock()
{
//启动 任务1
var task1 = Task.Run(() => Task1());
//启动 任务2
var task2 = Task.Run(() => Task2());
//等待两个任务完成
await Task.WhenAll(task1, task2);
}
//任务1
public static async Task Task1()
{
//任务1 首先获取 锁1
lock (lock1)
{
Console.WriteLine("任务1: 已获取 锁1");
//模拟一些操作
Task.Delay(1000).Wait();
//任务1 等待 锁2
Console.WriteLine("任务1: 等待获取 锁2");
lock (lock2)
{
Console.WriteLine("任务1: 已获取 锁2");
}
}
}
//任务2
public static async Task Task2()
{
//线程2 首先获取 锁2
lock (lock2)
{
Console.WriteLine("任务2: 已获取 锁2");
//模拟一些操作
Task.Delay(100).Wait();
// 任务2 等待 锁1
Console.WriteLine("任务2: 等待获取 锁1");
lock (lock1)
{
Console.WriteLine("任务2: 获取 锁1");
}
}
}
注:测试方法代码以及示例源码都已经上传至代码库,有兴趣的可以看看。https://gitee.com/hugogoos/Planner 。
最后此篇关于并发编程-死锁的产生、排查与解决方案的文章就讲到这里了,如果你想了解更多关于并发编程-死锁的产生、排查与解决方案的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我在 Chrome 上做了一些测试,requestAnimationFrame 产生了 61 fps 而 setTimeOut( callback, 0 ) 产生了 233 fps。 如果一个人想要超
当我调试代码时,我发现 GCC 和 Clang 都为 0.0/0.0 产生 nan,这是我所期望的,但 GCC 产生的 nan 将符号位设置为 1,而Clang 将其设置为 0(如果我没记错的话,与
Closed. This question does not meet Stack Overflow guidelines。它当前不接受答案。 想改善这个问题吗?更新问题,以便将其作为on-topic
我在 R Studio 中有一个时间序列。现在我想计算这个系列的log()。我尝试了以下方法: i <- (x-y) ii <- log(i) 但是我得到以下信息:Warning message: I
我有兴趣了解 JavaScript 的内部结构.我试图阅读 SpiderMonkey 的来源和 Rhino但是绕过我的头是相当复杂的。 我问的原因是:为什么像 (![]+[])[+!![]+[]] 生
我们在 Delphi 中使用标准 TWebbrowser 组件,该组件在内部使用 mshtml.dll。另外,我们使用注册表来确保页面使用新的渲染引擎( Web-Browser-Control-Spe
我必须实现一个序列化/反序列化类,并且我正在使用 System.Xml.Serialization 。我有一些IList类型属性并希望在 IList 中序列化解码属于具有特定区域性信息的列表的所有十进
我有一个 Java 应用程序,它读取包含 SQL 查询的 JSON 文件,并使用 JDBC 在数据库上触发它们。 现在我有 5 万个这样的文件,我需要生成 5 万个独立线程来读取每个文件并将它们上传到
我正在尝试将 TensorFlow 入门页面上的示例线性回归程序调整为二次回归。为此,我只是添加了另一个变量并更改了函数。然而,这似乎会导致 NaN 值。这是我的代码: import numpy as
申请后KernelPCA到我的数据并将其传递给分类器 ( SVC ) 我收到以下错误: ValueError: Input contains NaN, infinity or a value too
这背后的想法是,如果我的数据库中存在登录名(正确的用户名+密码),我将重定向到一个页面,并且在进行此身份验证后,他们可以将消息存储在文本文件中。代码非常简单尽管我不确定为什么会收到 IllegalSt
我有一个返回 log10 值的函数。在将它们转换为正常数字时,出现溢出错误。 OverflowError: (34, 'Numerical result out of range') 我检查了日志值,
nosetests 抛出一个 ImportError,尽管我认为这是一个正确配置的 virtualenv。 ==============================================
我是这个网站的新手,所以如果我做错了什么,我提前道歉。当我尝试使用 kivy-garden 的 ScrollLabel 时,它给了我一个错误。基本上我正在尝试创建一个控制台日志,并且我需要能够在文本框
任何人都对 MDSJ 有任何经验?以下输入仅产生 NaN 结果,我不明白为什么。文档非常稀少。 import mdsj.Data; import mdsj.MDSJ; public class MDS
我有一个非常简单的 scala jcuda 程序,它添加了一个非常大的数组。一切都编译和运行得很好,直到我想从我的设备复制超过 4 个字节到主机。当我尝试复制超过 4 个字节时,我收到 CUDA_ER
我正在使用 Hero 组件在两个页面之间创建动画。Hero 组件用于包装一个 Image 小部件(没问题)和一个 Container 小部件(有问题)。 抛出以下溢出错误: ══╡ EXCEPTIO
我无法理解页面 https://developer.mozilla.org/en/JavaScript/Reference/Operators/Special/void 中的这一段: This ope
当在 Angular 中使用不立即触发事件的异步管道时(http 请求或任何有延迟的可观察对象),第一个值为 null为什么会这样?如何避免这种情况? 第一个变化: SimpleChange {
如果一个导入的库生成了一个会 panic 的 goroutine 怎么办?在这种情况下,开发人员无法阻止程序退出。 就像在这段代码中一样,使用延迟恢复调用一个错误的库没有帮助,因为该库正在生成一个 p
我是一名优秀的程序员,十分优秀!