【C#|.NET】lock(this)其实是个坑

来自 【C#|.NET】lock(this)其实是个坑

这里不考虑分布式或者多台负载均衡的情况只考虑单台机器,多台服务器可以使用分布式锁。出于线程安全的原因,很多种场景大家可能看代码中看到lock的出现,尤其是在资金类的处理环节。 但是lock(this)真的达到你的需求了吗?下面用实例来说明

  理论常识不多说,回到业务场景,举个例子我们的需求一般就是在某个订单进入某个安全优先级比较高的流程时要针对这笔订单做到线程互斥。至于原因,这里再插一个概念,大部分orm在做更新操作时,实际上做的是全参数更新,所谓全参数更新,假如一个订单表上有10个字段,我们只需要更新其中的一个金额字段,但是在传统orm框架中实际上在订单的实体类中赋值了所有字段而在更新操作中这些字段全部参与了更新,所以在高并发的场景下,如果有2个线程针对同一个订单操作,并且没有额外的保护程序(例如数据库锁、版本号等)那么在这种传统框架下后一个线程更新可能就会覆盖掉前一个线程的操作。因此lock的手段可以看成是一道保护墙。 那么接下来我们通过实例看一下lock4种不同方式(并非4种类别)之间的区别

  代码很简单 在结果截图后直接附上

   1. Lock(this)

  可以看出lock(this),如果this是个普通的类非静态非单例,那么lock(this)并不满足我们的需求,甚至除了当前线程并看不出有任何作用。

  2. Lock(LockString)

   Lock(LockString) 从结果上来看比较契合要求,对于同一笔订单做到的线程互斥,对于不同订单即使用到了同一个类也不干扰。不过根据大家的回复意见LockString并不适合锁。

  3. Lock(Object)

  Lock(Object)和Lock(this)一样,因为根本原因2者方式是相同的。推荐!

  4. Lock(StaticObject)

  Lock(StaticObject) 实现了对于同一笔的订单线程互斥,但是不符合的是对于不同笔的订单同样进行了互斥。

  结论一目了然,理论的内容不赘述。下面贴代码

class Program
    {
        const string firstOrderId = "001";
        const string secondOrderId = "002";
        const string thirdOrderId = "003";

        static void Main()
        {
            test(LockType.LockThis);
            //test(LockType.LockString);
            //test(LockType.LockObject);
            //test(LockType.LockStaticObject);

            Console.ReadLine();
        }

        static void test(LockType lockType)
        {
            Console.ForegroundColor = ConsoleColor.Yellow;
            Console.WriteLine("------------测试相同订单------------");
            Console.ForegroundColor = ConsoleColor.White;
            OrderPay(firstOrderId, 1, lockType);
            OrderPay(firstOrderId, 2, lockType);
            OrderPay(firstOrderId, 3, lockType);
            Thread.Sleep(10000);

            Console.ForegroundColor = ConsoleColor.Yellow;
            Console.WriteLine("------------测试不同订单------------");
            Console.ForegroundColor = ConsoleColor.White;
            OrderPay(firstOrderId, 1, lockType);
            OrderPay(secondOrderId, 1, lockType);
            OrderPay(thirdOrderId, 1, lockType);
        }

        static void OrderPay(string orderId, int threadNo, LockType lockType)
        {
            new Thread(() => new Payment(orderId, threadNo).Pay(lockType)).Start();

            Thread.Sleep(10);
        }
    }
    public class Payment
    {
        private readonly string LockString;
        public readonly int ThreadNo;
        private readonly Object LockObj = new object();
        private static readonly Object StaticLockObj = new object();

        public Payment(string orderID, int threadNo)
        {
            LockString = orderID;
            ThreadNo = threadNo;
        }

        public void Pay(LockType lockType)
        {
            ShowMessage("等待锁资源");
            switch (lockType)
            {
                case LockType.LockThis:
                    lock (this)
                    {
                        showAction();
                    }
                    break;
                case LockType.LockString:
                    lock (LockString)
                    {
                        showAction();
                    }
                    break;
                case LockType.LockObject:
                    lock (LockObj)
                    {
                        showAction();
                    }
                    break;
                case LockType.LockStaticObject:
                    lock (StaticLockObj)
                    {
                        showAction();
                    }
                    break;
            }
            ShowMessage("释放锁");
        }

        private void showAction()
        {
            ShowMessage("进入锁并开始操作");
            Thread.Sleep(2000);
            ShowMessage("操作完成,完成时间为" + DateTime.Now);
        }

        private void ShowMessage(string message)
        {
            Console.WriteLine(String.Format("订单{0}的第{1}个线程 {2}", LockString, ThreadNo, message));
        }

    }

    public enum LockType
    {
        LockThis = 0,
        LockString = 1,
        LockObject = 2,
        LockStaticObject = 3
    }

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏NetCore

打造属于自己的支持版本迭代的Asp.Net Web Api Route

    在目前的主流架构中,我们越来越多的看到web Api的存在,小巧,灵活,基于Http协议,使它在越来越多的微服务项目或者移动项目充当很好的service...

237100
来自专栏me的随笔

【译】单元测试最佳实践

原文地址:Unit testing best practices PS:本文未翻译原文的全部内容,以下为译文。

13030
来自专栏码代码的陈同学

异常设计实践

前段时间结合SpringCloud网关处理异常写了篇 异常处理实践,侧重于异常的处理。作为强迫症患者,本次撰写下如何进行异常设计并提供具体的代码。

519180
来自专栏osc同步分享-java技术分享站

在springBoot项目中使用activiti

http://www.jvm123.com/2019/08/springboot-activiti/

3.9K70
来自专栏c#开发者

MSMQ消息大于4MB限制的解决办法

MSMQ 消息发送大于 4 导致 System.Messaging.MessageQueueException Mb。 察看本文应用于的产品 社区解决方案免责...

358130
来自专栏.NET后端开发

深入理解DIP、IoC、DI以及IoC容器

摘要 面向对象设计(OOD)有助于我们开发出高性能、易扩展以及易复用的程序。其中,OOD有一个重要的思想那就是依赖倒置原则(DIP),并由此引申出IoC、DI以...

34680
来自专栏java一日一条

编写可靠 Shell 脚本的 8 个建议

这八个建议,来源于键者几年来编写 shell 脚本的一些经验和教训。事实上开始写的时候还不止这几条,后来思索再三,去掉几条无关痛痒的,最后剩下八条。毫不夸张地说...

12220
来自专栏领域驱动设计DDD实战进阶

DDD实战进阶第一波(四):开发一般业务的大健康行业直销系统(搭建支持DDD的轻量级框架三)

上一篇文章我们讲了经典DDD架构对比传统三层架构的优势,以及经典DDD架构每一层的职责后,本篇文章将介绍基础结构层中支持DDD的轻量级框架的主要代码。 这里需要...

59650
来自专栏趣谈编程

synchronized与Lock 擂台之战

面试官:说说synchronized和Lock(或ReentrantLock)的区别 Java 1.5之后,对共享变量访问的协调机制除了之前的synchron...

202100
来自专栏逸鹏说道

.Net中的AOP系列之构建一个汽车租赁应用(下)

相似地,我们也要在Redeem方法中添加,这里不做了,省略。问题越来越明显了,横切关注点基本上占据了这个方法的一半代码。但是我们还没有做完,我们需要讨论一下异常...

36760

扫码关注云+社区

领取腾讯云代金券