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

news2025/1/10 23:20:51

欢迎来到《小5讲堂之知识点实践序列》文章，大家好，我是全栈小5。
这是2023年第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);
                }
            });
        }
    }
}