C#读写锁与并发控制

2024-09-07 00:04

本文主要是介绍C#读写锁与并发控制,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

前言

我们在使用一些资源的时候,有些资源可能是临界资源,就是同一时刻只能允许一个进程进行访问,比如打印机,或者文件的一些写入操作,我们知道,当我们有多个进程同时往同一个文件写入内容的时候,肯定出实现如下的一个错误。

The process cannot access the file ‘D:\MyProject\TestProject\并发测试\bin\Debug\net8.0\test.txt’ because it is being used by another process.

所以写入文件的那一段代码就是属于临界资源,但是在我们的程序中,现在都推荐使用异步操作,那我们在使用Task等异步方法的时候,有些程序段可能会在其他的线程进行处理,所以有些时候就不可避免的产生并发的问题,对于文件写入的操作,系统会直接报错,对于数据库写入或者更新的操作,可能就会产生死锁问题。当然解决这些问题并没有一个统一的解决方式,可以加锁,使用队列,数据库用主从复制,读写分离等方法来优化,那么本文主要来实验一下C#中读写锁的控制,了解一些原理,可能对我们解决问题有所帮助。

需求

现在我们有一个文本文件,可能会进行多线程的读和写操作,如何不报错,实现多线程的并发控制问题。

实战

这里还是新建一个控制台项目,然后新建一个名为test.txt的文本文件,设置属性复制到输出目录为始终复制。
接着新建四个方法,两个写操作,两个读操作。代码如下。

public static void WriteTxt1()
{File.WriteAllText("test.txt", "hello 111");
}
public static void WriteTxt2()
{File.WriteAllText("test.txt", "hello 222");
}
public static void ReadTxt1()
{var fileInfo = File.ReadAllText("test.txt");Console.WriteLine($"ReadTxt1读取内容:{fileInfo}");
}
public static void ReadTxt1()
{var fileInfo = File.ReadAllText("test.txt");Console.WriteLine($"ReadTxt2读取内容:{fileInfo}");
}

这里没什么好说的,就是非常简单的读取和写入文件的操作。然后在Main方法里添加如下代码。

static void Main(string[] args)
{Parallel.Invoke(WriteTxt1, WriteTxt2);Console.WriteLine("****数据查询完成****");Console.ReadKey();
}

这里使用Parallel来实现多线程的并发操作。就这样运行的话,不出意外会提示开头的错误,不允许多个进程同时写入文件。
所以我们新增一个变量。

private static ReaderWriterLockSlim lockSlim = new ReaderWriterLockSlim();

然后写入操作修改如下。

 public static void WriteTxt1(){lockSlim.EnterWriteLock();try{File.WriteAllText("test.txt", "hello 111");}finally{lockSlim.ExitWriteLock();}}public static void WriteTxt2(){lockSlim.EnterWriteLock();try{File.WriteAllText("test.txt", "hello 222");}finally{lockSlim.ExitWriteLock();}}

主要是增加了写锁和释放写锁。
读取操作就可以新增和释放读锁。代码如下。

 public static void ReadTxt1(){lockSlim.EnterReadLock();try{var fileInfo = File.ReadAllText("test.txt");Console.WriteLine($"ReadTxt1读取内容:{fileInfo}");}finally{lockSlim.ExitReadLock();}}public static void ReadTxt2(){lockSlim.EnterReadLock();try{var fileInfo = File.ReadAllText("test.txt");Console.WriteLine($"ReadTxt2读取内容:{fileInfo}");}finally{lockSlim.ExitReadLock();}}

总结

调试的时候可以使用Thread.Sleep(3000);来辅助调试,通过调试发现,如果在两个写入方法里都添加写锁,那么只会有一个线程可以继续往下执行,另一个线程的写操作,则一直停留在添加写锁的地方,当该资源区没有写锁的时候(其他写锁已释放),那么才可以添加新的写锁。这样就保证了临界资源的线性使用。

通过调试还可以发现以下规则。

  • 先加写锁,则不能在加读锁和写锁。
  • 先加读锁,还可以在加读锁,但不能加写锁。

结语

感谢您花时间阅读这篇文章,希望这些知识能为您的技术之旅增添一份力量。明天会更好!

Study hard and make progress every day.

欢迎关注下方微信公众号,一起学习,一起娱乐,一起进步,点击卡片可以查看公众号二维码哟。

这篇关于C#读写锁与并发控制的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

C#基础之委托详解(Delegate)

《C#基础之委托详解(Delegate)》:本文主要介绍C#基础之委托(Delegate),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 委托定义2. 委托实例化3. 多播委托(Multicast Delegates)4. 委托的用途事件处理回调函数LINQ

在C#中调用Python代码的两种实现方式

《在C#中调用Python代码的两种实现方式》:本文主要介绍在C#中调用Python代码的两种实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录C#调用python代码的方式1. 使用 Python.NET2. 使用外部进程调用 Python 脚本总结C#调

C#中的 StreamReader/StreamWriter 使用示例详解

《C#中的StreamReader/StreamWriter使用示例详解》在C#开发中,StreamReader和StreamWriter是处理文本文件的核心类,属于System.IO命名空间,本... 目录前言一、什么是 StreamReader 和 StreamWriter?1. 定义2. 特点3. 用

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法:给并发装上"节流阀"三、进阶控制

Redis中高并发读写性能的深度解析与优化

《Redis中高并发读写性能的深度解析与优化》Redis作为一款高性能的内存数据库,广泛应用于缓存、消息队列、实时统计等场景,本文将深入探讨Redis的读写并发能力,感兴趣的小伙伴可以了解下... 目录引言一、Redis 并发能力概述1.1 Redis 的读写性能1.2 影响 Redis 并发能力的因素二、

使用DrissionPage控制360浏览器的完美解决方案

《使用DrissionPage控制360浏览器的完美解决方案》在网页自动化领域,经常遇到需要保持登录状态、保留Cookie等场景,今天要分享的方案可以完美解决这个问题:使用DrissionPage直接... 目录完整代码引言为什么要使用已有用户数据?核心代码实现1. 导入必要模块2. 关键配置(重点!)3.

SpringSecurity 认证、注销、权限控制功能(注销、记住密码、自定义登入页)

《SpringSecurity认证、注销、权限控制功能(注销、记住密码、自定义登入页)》SpringSecurity是一个强大的Java框架,用于保护应用程序的安全性,它提供了一套全面的安全解决方案... 目录简介认识Spring Security“认证”(Authentication)“授权” (Auth

python之流程控制语句match-case详解

《python之流程控制语句match-case详解》:本文主要介绍python之流程控制语句match-case使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录match-case 语法详解与实战一、基础值匹配(类似 switch-case)二、数据结构解构匹

如何使用C#串口通讯实现数据的发送和接收

《如何使用C#串口通讯实现数据的发送和接收》本文详细介绍了如何使用C#实现基于串口通讯的数据发送和接收,通过SerialPort类,我们可以轻松实现串口通讯,并结合事件机制实现数据的传递和处理,感兴趣... 目录1. 概述2. 关键技术点2.1 SerialPort类2.2 异步接收数据2.3 数据解析2.

C#原型模式之如何通过克隆对象来优化创建过程

《C#原型模式之如何通过克隆对象来优化创建过程》原型模式是一种创建型设计模式,通过克隆现有对象来创建新对象,避免重复的创建成本和复杂的初始化过程,它适用于对象创建过程复杂、需要大量相似对象或避免重复初... 目录什么是原型模式?原型模式的工作原理C#中如何实现原型模式?1. 定义原型接口2. 实现原型接口3