这里不考虑分布式或者多台负载均衡的情况只考虑单台机器,多台服务器可以使用分布式锁。出于线程安全的原因,很多种场景大家可能看代码中看到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
}

  希望对大家有帮助。

最新文章

  1. 个人总结深入.NET平台和C#编程
  2. SOAPUI使用教程-入门REST测试
  3. Android开发能够帮你更好开发的19个开发工具
  4. ArcGIS 裁剪地图显示范围
  5. sitemesh2在tomcat和weblogic中同时使用的配置问题
  6. eclipse 中发布 maven 项目到 tomcat
  7. QQ登入(6)腾讯微博-获取微博用户信息,发送微博
  8. Codevs 2611 观光旅游
  9. HDU 2874 Connections between cities (LCA)
  10. English Audio-Books
  11. Objective-C 成员变量的访问修饰即成员变量可见性解析
  12. 'EntityValidationErrors' property for more details
  13. ios入门之c语言篇——基本函数——5——素数判断
  14. call, apply的用法意义以及区别是什么
  15. java 科学计算库
  16. [Python]根据地址从maps文件中找相应的库名
  17. A.02.00—功能定义与唤醒—起始
  18. enum & json 之间的转换
  19. cent6.x配置主机名及静态网络
  20. 用docker-compose部署postgres+ postgis

热门文章

  1. java后台开发传输乱码&&接口post传参失败
  2. ftp客户端命令使用简记
  3. 你的联动够快够小吗——基于Telerik(ASP.NET平台)
  4. 【Leetcode】【Medium】word search
  5. Asp.Net Web API 2第四课——HttpClient消息处理器
  6. Jquery最全过滤器总结
  7. 冲刺阶段 day 4
  8. Atitit..文件上传组件选型and最佳实践总结(2)----断点续传
  9. paip.数据挖掘--导出词库 清理太长的iptcode
  10. paip. java resin 远程 调试 java resin remote debug