当前位置：首页 > news >正文

【C#】知识点实践序列之Lock简单解决并发引起数据重复问题

news 2025/8/18 9:21:50

欢迎来到《小5讲堂之知识点实践序列》文章，大家好，我是全栈小5。
这是2024年第3篇文章，此篇文章是C#知识点实践序列文章，博主能力有限，理解水平有限，若有不对之处望指正！
本篇在Lock锁定代码块基础上进行简单解决并发问题，确保不会出现重复数据。

在这里插入图片描述

前言

前两篇文章已经回顾基本概念一级Lock锁定代码块的实践例子，以及简单了解了多线程的基本信息。

实践场景

有一个用户注册的功能，通过简单并发测试，在不进行索引等情况下，对比加锁和不加锁，用户表重复记录情况

用户编码重复

在并发情况下，如果方法代码和数据库没有做唯一处理，那么进行用户注册时，用户编码重复概率是很大的。
下面是逻辑是，设置3个异步方法模拟3个并发访问，他们之间就极有可能是同时执行同一个方法，用户编码就可能会重复。

效果

在这里插入图片描述

重复数据
从下图可以知道，GZ0008、GZ0018、GZ00021，这就会出现重复了，相对于用户编码就不是唯一，也就无法满足实际场景。

代码

namespace XxxData
{/// <summary>/// 解决数据重复/// </summary>public partial class LockUser : Form{public LockUser(){InitializeComponent();CheckForIllegalCrossThreadCalls = false;}private void Form1_Load(object sender, EventArgs e){}int userCodeIndex = 0;private void TargetData(){userCodeIndex += 1;txtInfo.AppendText($"GZ{userCodeIndex.ToString().PadLeft(5, '0')}\r\n");}private void btnA_Click(object sender, EventArgs e){// ===模拟并发===// 用户并发a区域Task.Run(() =>{for(int i = 0; i < 10; i++){TargetData();Thread.Sleep(10);}});// 用户并发b区域Task.Run(() =>{for (int i = 0; i < 10; i++){TargetData();Thread.Sleep(10);}});// 用户并发c区域Task.Run(() =>{for (int i = 0; i < 10; i++){TargetData();Thread.Sleep(10);}});}}
}

用户编码唯一

基于用户编码唯一原则，那么解决的方法有很多，这里我们通过锁定代码块的方式来解决，也就是同步机制来解决。
同步机制的最大特点就是，即使有多个请求同一时间调用同一个方法，它也会遵循一个一个执行完，从而用户编码也只会顺序叠加。

效果

方法部分锁

int userCodeIndex = 0;
private void TargetData(int num)
{txtInfo.AppendText($"用户【{num}】进入方法，等待添加！\r\n");lock (this){userCodeIndex += 1;txtInfo.AppendText($"GZ{userCodeIndex.ToString().PadLeft(5, '0')}\r\n\r\n");}
}

在这里插入图片描述

方法全部锁

int userCodeIndex = 0;
private void TargetData(int num)
{lock (this){txtInfo.AppendText($"用户【{num}】进入方法，等待添加！\r\n");userCodeIndex += 1;txtInfo.AppendText($"GZ{userCodeIndex.ToString().PadLeft(5, '0')}\r\n\r\n");}
}

在这里插入图片描述

代码

namespace XxxData
{/// <summary>/// 解决数据重复/// </summary>public partial class LockUser : Form{public LockUser(){InitializeComponent();CheckForIllegalCrossThreadCalls = false;}private void Form1_Load(object sender, EventArgs e){}int userCodeIndex = 0;private void TargetData(int num){lock (this){txtInfo.AppendText($"用户【{num}】进入方法，等待添加！\r\n");userCodeIndex += 1;txtInfo.AppendText($"GZ{userCodeIndex.ToString().PadLeft(5, '0')}\r\n\r\n");}}private void btnA_Click(object sender, EventArgs e){// ===模拟并发===// 用户并发a区域Task.Run(() =>{for(int i = 0; i < 10; i++){TargetData(i + 1);Thread.Sleep(10);}});// 用户并发b区域Task.Run(() =>{for (int i = 10; i < 20; i++){TargetData(i + 1);Thread.Sleep(10);}});// 用户并发c区域Task.Run(() =>{for (int i = 20; i < 30; i++){TargetData(i + 1);Thread.Sleep(10);}});}}
}