C# lock使用详解
总目录
前言
在 C# 多线程编程中,lock 关键字是一种非常重要的同步机制,用于确保同一时间只有一个线程可以访问特定的代码块,从而避免多个线程同时操作共享资源时可能出现的数据竞争和不一致问题。以下是关于 lock 关键字的详细使用介绍。
一、基本概念
lock 关键字提供了一种简单的方法来实现互斥锁(mutex),它通过锁定一个对象来保护临界区内的代码。当一个线程进入被 lock 保护的代码块时,其他尝试进入同一代码块的线程将被阻塞,直到第一个线程完成并释放锁。
lock 关键字的基本语法如下:
lock (object)
{// 要保护的代码块/临界区代码
}
其中,object 是一个引用类型的对象,通常是一个私有的静态或实例成员变量,通常称为 “锁对象”。lock 语句会获取这个锁对象的独占锁,当一个线程进入 lock 块时,它会尝试获取锁对象的锁。如果锁对象当前没有被其他线程持有,该线程会获取锁并执行 lock 块内的代码;如果锁对象已经被其他线程持有,当前线程会被阻塞,直到持有锁的线程退出 lock 块并释放锁。
为了确保线程安全,所有需要同步访问的代码都应该使用同一个锁对象。
二、使用
1. 基本使用
下面是一个简单的示例,展示了如何使用 lock 关键字来保护共享资源:
using System;
using System.Threading;class Program
{private static int sharedCounter = 0;private static readonly object lockObject = new object();static void Main(){// 创建两个线程Thread thread1 = new Thread(IncrementCounter);Thread thread2 = new Thread(IncrementCounter);// 启动线程thread1.Start();thread2.Start();// 等待两个线程执行完毕thread1.Join();thread2.Join();// 输出最终的计数器值Console.WriteLine($"Final counter value: {sharedCounter}");}static void IncrementCounter(){for (int i = 0; i < 100000; i++){// 使用 lock 关键字保护共享资源lock (lockObject){sharedCounter++;}}}
}
在这个示例中,sharedCounter 是一个共享资源,多个线程可能同时对其进行递增操作。为了避免数据竞争,我们使用 lock 关键字来保护 sharedCounter 的递增操作。lockObject 是一个用于锁定的对象,两个线程在执行 sharedCounter++ 之前都会尝试获取 lockObject 的锁,只有获取到锁的线程才能执行递增操作,从而确保同一时间只有一个线程可以修改 sharedCounter 的值。
2. 静态 vs 实例锁
根据锁对象是静态成员还是实例成员,lock 可以保护类级别的资源或对象级别的资源:
- 静态锁:用于保护类的所有实例之间的共享资源。
- 实例锁:用于保护单个对象的状态。
示例:静态锁 vs 实例锁
public class Singleton
{private static readonly object _staticLock = new object();private readonly object _instanceLock = new object();public void StaticMethod(){lock (_staticLock){// Shared resource access}}public void InstanceMethod(){lock (_instanceLock){// Object-specific resource access}}
}
三、 注意事项
1. 锁的粒度
合理控制锁的粒度对于性能至关重要:
- 粗粒度锁:锁定整个方法或较大的代码段。虽然简单易用,但可能导致不必要的阻塞,影响吞吐量。
- 细粒度锁:只锁定必要的最小代码片段。这样可以减少等待时间,提高并发性,但也增加了复杂性和潜在的死锁风险。
最佳实践
- 要合理控制锁的粒度,即 lock 块内的代码量。如果锁的粒度过大,会导致其他线程等待的时间过长,降低程序的性能;如果锁的粒度过小,可能无法有效保护共享资源,仍然会出现数据竞争问题。
- 尽量缩小锁的作用范围,只锁定那些真正需要同步的代码行。此外,避免在锁内部执行长时间运行的操作,如I/O访问或复杂的计算。
2. 避免死锁
死锁是指两个或多个线程相互等待对方释放锁,从而导致所有线程都无法继续执行的情况。为了避免死锁,应该尽量减少锁的嵌套,确保线程按照相同的顺序获取锁。
关于死锁详情,下文会有详细介绍。
3. 锁对象的选择
- 专用锁对象:确保所有需要同步的代码使用相同的锁对象。通常建议使用一个专用的、私有的引用类型对象作为锁对象,如上面示例中的 lockObject。这样可以避免不同的代码块或类之间意外地共享同一个锁对象,从而减少死锁和其他同步问题的发生。
- 避免使用 this:在实例方法中,不建议使用 this 作为锁对象,因为其他代码可能会无意中锁定同一个对象,导致意想不到的结果。例如:
class MyClass
{private int counter = 0;public void Increment(){// 不推荐使用 this 作为锁对象lock (this){counter++;}}
}
- 避免使用字符串:也不建议使用字符串作为锁对象,因为字符串具有字符串驻留机制,可能会导致不同的代码块使用相同的字符串作为锁对象,从而引发同步问题。
四、死锁
死锁指的是两个或多个线程相互等待对方释放锁,从而导致所有线程都无法继续执行的情况
1. 死锁示例
以下是一个用 C# 编写的会发生死锁的案例,这个案例模拟了两个线程互相等待对方释放锁的情况,从而导致死锁。
using System;
using System.Threading;class DeadlockExample
{// 定义两个锁对象private static readonly object lock1 = new object();private static readonly object lock2 = new object();static void Main(){// 创建第一个线程Thread thread1 = new Thread(Function1);// 创建第二个线程Thread thread2 = new Thread(Function2);// 启动第一个线程thread1.Start();// 稍微延迟一下,让 thread1 有机会先获取 lock1Thread.Sleep(100);// 启动第二个线程thread2.Start();// 等待两个线程执行完成thread1.Join();thread2.Join();Console.WriteLine("程序执行结束");}static void Function1(){// 线程 1 先获取 lock1lock (lock1){Console.WriteLine("线程 1 已获取 lock1,正在尝试获取 lock2...");// 稍微延迟一下,增加死锁发生的概率Thread.Sleep(200);// 线程 1 尝试获取 lock2lock (lock2){Console.WriteLine("线程 1 已获取 lock2");}}}static void Function2(){// 线程 2 先获取 lock2lock (lock2){Console.WriteLine("线程 2 已获取 lock2,正在尝试获取 lock1...");// 稍微延迟一下,增加死锁发生的概率Thread.Sleep(200);// 线程 2 尝试获取 lock1lock (lock1){Console.WriteLine("线程 2 已获取 lock1");}}}
}
代码解释
- 锁对象的定义:
- lock1 和 lock2 是两个静态的、只读的 object 类型对象,作为锁使用。
- 线程的创建和启动:
- thread1 执行 Function1 方法,thread2 执行 Function2 方法。
- 在启动 thread2 之前,让主线程休眠 100 毫秒,目的是让 thread1 有机会先获取 lock1。
- Function1 方法:
- 线程 1 首先获取 lock1,然后输出提示信息,表示正在尝试获取 lock2。
- 线程 1 休眠 200 毫秒,增加死锁发生的概率。
- 线程 1 尝试获取 lock2。
- Function2 方法:
- 线程 2 首先获取 lock2,然后输出提示信息,表示正在尝试获取 lock1。
- 线程 2 休眠 200 毫秒,增加死锁发生的概率。
- 线程 2 尝试获取 lock1。
死锁的产生过程
- 线程 1 先获取了 lock1,然后尝试获取 lock2。
- 线程 2 先获取了 lock2,然后尝试获取 lock1。
- 此时,线程 1 持有 lock1 并等待 lock2,而线程 2 持有 lock2 并等待 lock1,两个线程互相等待对方释放锁,从而导致死锁,程序将无法继续执行下去。
运行这个程序时,你会看到控制台输出类似以下的内容:
线程 1 已获取 lock1,正在尝试获取 lock2...
线程 2 已获取 lock2,正在尝试获取 lock1...
之后程序就会停滞,因为发生了死锁。
2. 如何避免死锁
在多线程编程里,死锁是一个常见且棘手的问题,它指的是两个或多个线程相互等待对方释放锁,从而导致所有线程都无法继续执行的情况。以下是一些避免死锁问题的有效方法:
1) 按顺序获取锁
多个线程在需要获取多个锁时,如果都按照相同的顺序获取锁,就能避免死锁。例如,假设有两个锁 lockA 和 lockB,所有线程都先获取 lockA 再获取 lockB,这样就不会出现一个线程持有 lockA 等待 lockB,而另一个线程持有 lockB 等待 lockA 的情况。
using System;
using System.Threading;class Program
{private static readonly object lockA = new object();private static readonly object lockB = new object();static void Main(){Thread thread1 = new Thread(() =>{lock (lockA){Console.WriteLine("Thread 1 acquired lockA");Thread.Sleep(100);lock (lockB){Console.WriteLine("Thread 1 acquired lockB");}}});Thread thread2 = new Thread(() =>{lock (lockA){Console.WriteLine("Thread 2 acquired lockA");Thread.Sleep(100);lock (lockB){Console.WriteLine("Thread 2 acquired lockB");}}});thread1.Start();thread2.Start();thread1.Join();thread2.Join();}
}
2) 设置锁的超时时间
为锁操作设置超时时间,当线程在规定时间内无法获取锁时,就放弃获取锁并进行其他处理。这样可以避免线程无限期地等待锁,从而打破死锁的条件。在 C# 中,可以使用 Monitor.TryEnter 方法来实现这一点。
using System;
using System.Threading;class Program
{private static readonly object lockA = new object();private static readonly object lockB = new object();static void Main(){Thread thread1 = new Thread(() =>{if (Monitor.TryEnter(lockA, 1000)){try{Console.WriteLine("Thread 1 acquired lockA");if (Monitor.TryEnter(lockB, 1000)){try{Console.WriteLine("Thread 1 acquired lockB");}finally{Monitor.Exit(lockB);}}}finally{Monitor.Exit(lockA);}}});Thread thread2 = new Thread(() =>{if (Monitor.TryEnter(lockA, 1000)){try{Console.WriteLine("Thread 2 acquired lockA");if (Monitor.TryEnter(lockB, 1000)){try{Console.WriteLine("Thread 2 acquired lockB");}finally{Monitor.Exit(lockB);}}}finally{Monitor.Exit(lockA);}}});thread1.Start();thread2.Start();thread1.Join();thread2.Join();}
}
3) 减少锁的嵌套
锁的嵌套会增加死锁的风险,因为嵌套的锁会使线程持有多个锁的时间变长,增加了与其他线程发生死锁的可能性。尽量减少锁的嵌套,将需要锁保护的代码逻辑拆分成更小的部分,只在必要时使用锁。
4) 使用资源层次结构
为共享资源定义一个层次结构,线程只能按照资源的层次顺序获取锁。例如,将资源分为不同的级别,线程必须先获取高级别的资源锁,再获取低级别的资源锁。这样可以确保线程获取锁的顺序是一致的,避免死锁。
5) 使用无锁算法和数据结构
在某些情况下,可以使用无锁算法和数据结构来替代传统的锁机制。无锁算法和数据结构通过原子操作(如 Interlocked 类提供的方法)来实现线程安全,避免了锁的使用,从而从根本上消除了死锁的可能性。例如,使用 ConcurrentQueue、ConcurrentDictionary<TKey, TValue> 等并发集合类。
6) 死锁检测和恢复机制
在程序中实现死锁检测机制,定期检查是否存在死锁情况。如果检测到死锁,可以采取一些恢复措施,如终止某些线程或释放某些锁,以打破死锁状态。不过,死锁检测和恢复机制的实现比较复杂,需要根据具体的应用场景进行设计。
五、lock 的实现原理
lock 关键字实际上是 Monitor 类的语法糖,上述 lock 语句等价于以下代码:
object obj = lockObject;
bool lockTaken = false;
try
{Monitor.Enter(obj, ref lockTaken);// 要保护的代码块sharedCounter++;
}
finally
{if (lockTaken){Monitor.Exit(obj);}
}
Monitor.Enter 方法用于获取锁对象的锁,Monitor.Exit 方法用于释放锁对象的锁。try-finally 块确保无论 lock 块内的代码是否抛出异常,锁都会被正确释放。
六、适用场景
lock 关键字适用于需要保护共享资源的多线程场景,例如:
- 对共享变量的读写操作,如上面示例中的计数器。
- 对共享集合的操作,如对 List、Dictionary<TKey, TValue> 等集合的添加、删除、修改操作。
- 对共享文件、数据库连接等资源的访问。
- 对于高并发场景,考虑使用 ReaderWriterLockSlim 等更灵活的同步机制。
七、其他
在异步编程 async 和 await 中,传统的 lock 并不适合,因为它会导致线程阻塞。取而代之的是,你应该考虑使用 SemaphoreSlim 或 AsyncLock 等替代方案。
using System.Threading;
using System.Threading.Tasks;public class AsyncCounter
{private int _count = 0;private readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);public async Task IncrementAsync(){await _semaphore.WaitAsync();try{_count++;}finally{_semaphore.Release();}}
}
总之,lock 关键字是 C# 中一种简单而有效的同步机制,能够帮助开发者确保多线程环境下共享资源的安全访问。但在使用时需要注意锁对象的选择、锁的粒度和避免死锁等问题。
结语
回到目录页:C#/.NET 知识汇总
希望以上内容可以帮助到大家,如文中有不对之处,还请批评指正。
参考资料:
lock 语句 - 确保对共享资源的独占访问权限
Locker 和 Monitor 锁
C#多线程系列(2):多线程锁lock和Monitor
相关文章:
C# lock使用详解
总目录 前言 在 C# 多线程编程中,lock 关键字是一种非常重要的同步机制,用于确保同一时间只有一个线程可以访问特定的代码块,从而避免多个线程同时操作共享资源时可能出现的数据竞争和不一致问题。以下是关于 lock 关键字的详细使用介绍。 一…...
C# 接口介绍
.NET学习资料 .NET学习资料 .NET学习资料 一、接口的定义 在 C# 中,接口是一种特殊的抽象类型,它定义了一组方法签名,但不包含方法的实现。接口使用interface关键字来声明。例如,定义一个表示形状的接口IShape: in…...
第三周 树
猫猫和企鹅 分数 10 全屏浏览 切换布局 作者 姜明欣 单位 河北大学 王国里有 nn 个居住区,它们之间有 n−1 条道路相连,并且保证从每个居住区出发都可以到达任何一个居住区,并且每条道路的长度都为 1。 除 1号居住区外,每个居…...
OpenAI 实战进阶教程 - 第四节: 结合 Web 服务:构建 Flask API 网关
目标 学习将 OpenAI 接入 Web 应用,构建交互式 API 网关理解 Flask 框架的基本用法实现 GPT 模型的 API 集成并返回结果 内容与实操 一、环境准备 安装必要依赖: 打开终端或命令行,执行以下命令安装 Flask 和 OpenAI SDK: pip i…...
Nginx 中文文档
文章来源:nginx 文档 -- nginx中文文档|nginx中文教程 nginx 文档 介绍 安装 nginx从源构建 nginx新手指南管理员指南控制 nginx连接处理方法设置哈希调试日志记录到 syslog配置文件测量单位命令行参数适用于 Windows 的 nginx支持 QUIC 和 HTTP/3 nginx 如何处理…...
Java 泛型<? extends Object>
在 Java 泛型中,<? extends Object> 和 <?> 都表示未知类型,但它们在某些情况下有细微的差异。泛型的引入是为了消除运行时错误并增强类型安全性,使代码更具可读性和可维护性。 在 JDK 5 中引入了泛型,以消除编译时…...
鲸鱼算法 matlab pso
算法原理 鲸鱼优化算法的核心思想是通过模拟座头鲸的捕食过程来进行搜索和优化。座头鲸在捕猎时会围绕猎物游动并产生气泡网,迫使猎物聚集。这一行为被用来设计搜索策略,使算法能够有效地找到全局最优解。 算法步骤 初始化:随机生成一…...
Hot100之堆
我们的PriorityQueue默认为最小堆,堆顶总是为最小 215数组中的第K个最大元素 题目 思路解析 暴力解法(不符合时间复杂度) 题目要求我们找到「数组排序后的第 k 个最大的元素,而不是第 k 个不同的元素」。「数组排序后的第 k …...
KNIME:开源 AI 数据科学
KNIME(Konstanz Information Miner)是一款开源且功能强大的数据科学平台,由德国康斯坦茨大学的软件工程师团队开发,自2004年推出以来,广泛应用于数据分析、数据挖掘、机器学习和可视化等领域。以下是对KNIME的深度介绍…...
Office / WPS 公式、Mathtype 公式输入花体字、空心字
注:引文主要看注意事项。 1、Office / WPS 公式中字体转换 花体字 字体选择 “Eulid Math One” 空心字 字体选择 “Eulid Math Two” 2、Mathtype 公式输入花体字、空心字 2.1 直接输入 花体字 在 mathtype 中直接输入 \mathcal{L} L \Large \mathcal{L} L…...
[HOT 100] 2824. 统计和小于目标的下标对数目
文章目录 1. 题目链接2. 题目描述3. 题目示例4. 解题思路5. 题解代码6. 复杂度分析 1. 题目链接 2824. 统计和小于目标的下标对数目 - 力扣(LeetCode) 2. 题目描述 给你一个下标从 0 开始长度为 n 的整数数组 nums 和一个整数 target ,请你…...
建表注意事项(2):表约束,主键自增,序列[oracle]
没有明确写明数据库时,默认基于oracle 约束的分类 用于确保数据的完整性和一致性。约束可以分为 表级约束 和 列级约束,区别在于定义的位置和作用范围 复合主键约束: 主键约束中有2个或以上的字段 复合主键的列顺序会影响索引的使用,需谨慎设计 添加…...
Ubuntu20.04 磁盘空间扩展教程
Ubuntu20.04 磁盘空间扩展教程_ubuntu20 gpart扩容-CSDN博客文章浏览阅读2w次,点赞38次,收藏119次。执行命令查看系统容量相关的数据:df -h当前容量为20G,已用18G(96%),可用844M,可用…...
冯诺依曼体系架构和操作系统的概念
1.冯诺依曼体系架构 计算机的硬件大部分都遵循冯诺依曼体系架构,其图示如下 这里的存储器指的是内存,是一种断电易失的设备。 速度快 而磁盘,是一种永久存储的设备,其属于外设既是输出设备又是输入设备。速度慢 而运算器是一种…...
OpenGL学习笔记(六):Transformations 变换(变换矩阵、坐标系统、GLM库应用)
文章目录 向量变换使用GLM变换(缩放、旋转、位移)将变换矩阵传递给着色器坐标系统与MVP矩阵三维变换绘制3D立方体 & 深度测试(Z-buffer)练习1——更多立方体 现在我们已经知道了如何创建一个物体、着色、加入纹理。但它们都还…...
Linux第105步_基于SiI9022A芯片的RGB转HDMI实验
SiI9022A是一款HDMI传输芯片,可以将“音视频接口”转换为HDMI或者DVI格式,是一个视频转换芯片。本实验基于linux的驱动程序设计。 SiI9022A支持输入视频格式有:xvYCC、BTA-T1004、ITU-R.656,内置DE发生器,支持SYNC格式…...
测试工程师的DS使用指南
目录 引言DeepSeek在测试设计中的应用 2.1 智能用例生成2.2 边界值分析2.3 异常场景设计DeepSeek在自动化测试中的应用 3.1 脚本智能转换3.2 日志智能分析3.3 测试数据生成DeepSeek在质量保障体系中的应用 4.1 测试策略优化4.2 缺陷模式预测4.3 技术方案验证DeepSeek在测试效能…...
Qt常用控件 输入类控件
文章目录 1.QLineEdit1.1 常用属性1.2 常用信号1.3 例子1,录入用户信息1.4 例子2,正则验证手机号1.5 例子3,验证输入的密码1.6 例子4,显示密码 2. QTextEdit2.1 常用属性2.2 常用信号2.3 例子1,获取输入框的内容2.4 例…...
linux运行级别
运行级别:指linux系统在启动和运行过程中所处的不同的状态。 运行级别之间的切换:init (级别数) 示例: linux的运行级别一共有7种,分别是: 运行级别0:停机状态 运行级别1:单用户模式/救援模式…...
数据结构课程设计(四)校园导航
4 校园导航 4.1 需求规格说明 【问题描述】 一个学校平面图,至少包括10个以上的场所,每个场所带有编号、坐标、名称、类别等信息,两个场所间可以有路径相通,路长(耗时)各有不同。要求读取该校园平面图&a…...
50【Windows与Linux】
大家可能有些人听过Linux系统,很多初学者被灌输的理念就是服务器必须要装Linux系统 什么是系统? 比如你的电脑是Windows系统的,你手机是Android系统的,物理设备都需要系统,系统你可以理解成直接控制物理设备的一个东…...
蓝桥杯python基础算法(2-2)——基础算法(D)——进制转换*
目录 五、进制转换 十进制转任意进制,任意进制转十进制 例题 P1230 进制转换 作业 P2095 进制转化 作业 P2489 进制 五、进制转换 十进制转任意进制,任意进制转十进制 int_to_char "0123456789ABCDEF" def Ten_to_K(k, x):answer "…...
CSS 溢出内容处理:从基础到实战
CSS 溢出内容处理:从基础到实战 1. 什么是溢出?示例代码:默认溢出行为 2. 使用 overflow 属性控制溢出2.1 使用 overflow: hidden 裁剪内容示例代码:裁剪溢出内容 2.2 使用 overflow: scroll 显示滚动条示例代码:显示滚…...
嵌入式知识点总结 操作系统 专题提升(四)-上下文
针对于嵌入式软件杂乱的知识点总结起来,提供给读者学习复习对下述内容的强化。 目录 1.上下文有哪些?怎么理解? 2.为什么会有上下文这种概念? 3.什么情况下进行用户态到内核态的切换? 4.中断上下文代码中有哪些注意事项? 5.请问线程需要保存哪些…...
Elasticsearch基本使用详解
文章目录 Elasticsearch基本使用详解一、引言二、环境搭建1、安装 Elasticsearch2、安装 Kibana(可选) 三、索引操作1、创建索引2、查看索引3、删除索引 四、数据操作1、插入数据2、查询数据(1)简单查询(2)…...
携程Android开发面试题及参考答案
在项目中,给别人发的动态点赞功能是如何实现的? 数据库设计:首先要在数据库中为动态表添加一个点赞字段,用于记录点赞数量,同时可能需要一个点赞关系表,记录用户与动态之间的点赞关联,包括点赞时间等信息。界面交互:在 Android 界面上,为点赞按钮设置点击事件监听器。…...
xxl-job 在 Java 项目的使用 以一个代驾项目中的订单模块举例
能搜到这里的最起码一定知道 xxl-job 是用来干什么的,我就不多啰嗦怎么下载以及它的历史了 首先我们要知道 xxl-job 这个框架的结构,如下图: xxl-job-master:xxl-job-admin:调度中心xxl-job-core:公共依赖…...
Alibaba开发规范_异常日志之日志规约:最佳实践与常见陷阱
文章目录 引言1. 使用SLF4J日志门面规则解释代码示例正例反例 2. 日志文件的保存时间规则解释 3. 日志文件的命名规范规则解释代码示例正例反例 4. 使用占位符进行日志拼接规则解释代码示例正例反例 5. 日志级别的开关判断规则解释代码示例正例反例 6. 避免重复打印日志规则解释…...
【数据分析】案例03:当当网近30日热销图书的数据采集与可视化分析(scrapy+openpyxl+matplotlib)
当当网近30日热销图书的数据采集与可视化分析(scrapy+openpyxl+matplotlib) 当当网近30日热销书籍官网写在前面 实验目的:实现当当网近30日热销图书的数据采集与可视化分析。 电脑系统:Windows 使用软件:Visual Studio Code Python版本:python 3.12.4 技术需求:scrapy、…...
需求分析应该从哪些方面来着手做?
需求分析一般可从以下几个方面着手: 业务需求方面 - 与相关方沟通:与业务部门、客户等进行深入交流,通过访谈、问卷调查、会议讨论等方式,明确他们对项目的期望、目标和整体业务需求,了解项目要解决的业务问题及达成的…...
