栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

java乐观锁原理与实现案例分析

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

java乐观锁原理与实现案例分析

本文实例讲述了java乐观锁原理与实现。分享给大家供大家参考,具体如下:

简单说说乐观锁。乐观锁是相对于悲观锁而言。悲观锁认为,这个线程,发生并发的可能性极大,线程冲突几率大,比较悲观。一般用synchronized实现,保证每次操作数据不会冲突。乐观锁认为,线程冲突可能性小,比较乐观,直接去操作数据,如果发现数据已经被更改(通过版本号控制),则不更新数据,再次去重复 所需操作,知道没有冲突(使用递归算法)。

因为乐观锁使用递归+版本号控制  实现,所以,如果线程冲突几率大,使用乐观锁会重复很多次操作(包括查询数据库),尤其是递归部分逻辑复杂,耗时和耗性能,是低效不合适的,应考虑使用悲观锁。

乐观锁悲观锁的选择:

  • 乐观锁:并发冲突几率小,对应模块递归操作简单    时使用
  • 悲观锁:并发几率大,对应模块操作复杂 时使用

下面给出一个乐观锁实例:


public List automaticAssign(Map paramMap){
    //派送规则
    String changeSortSet = RedisCacheUtil.getValue(CACHE_TYPE.APP, "changeSortSet");
    if (StringUtils.isBlank(changeSortSet)) {
 changeSortSet = customerManager.getDictionaryByCode("changeSortSet");
 if (StringUtils.isNotBlank(changeSortSet)) {
     RedisCacheUtil.addValue(CACHE_TYPE.APP, "changeSortSet", changeSortSet,30,TimeUnit.DAYS);
 } else {
     changeSortSet = ConstantsUtil.AssignRule.FIFO; // 默认先进先审
 }
    }
    AutomaticAssignDto automaticAssignDto = new AutomaticAssignDto();
    automaticAssignDto.setChangeSortSet(changeSortSet);
    automaticAssignDto.setUserTeam(CommonUtils.getValue(paramMap, "userTeam"));
    List waitCheckList = automaticAssignMybatisDao.automaticAssignOrder(automaticAssignDto);
    if(waitCheckList != null && waitCheckList.size()>0){
 automaticAssignDto = waitCheckList.get(0);
 automaticAssignDto.setSendStatus(ConstantsUtil.SendStatus.SEND);
 automaticAssignDto.setBindTime(new Date());
 automaticAssignDto.setUserId(Long.parseLong(paramMap.get("userId").toString()) );
 int sum = automaticAssignMybatisDao.bindAutomaticAssignInfo(automaticAssignDto);
 if(sum == 1){
     return waitCheckList;
 }else{
     //已被更新 则再次获取
     return automaticAssign(paramMap);
 }
    }else{
 return null;
    }
}

对应更新的sql:


  UPDATE t_automatic_assign 
  SET 
 SEND_STATUS = #{sendStatus} ,
 BIND_TIME = SYSDATE() ,
 LOCKED_FINISHTIME = SYSDATE(),
 USER_ID = #{userId} ,
 VERSION = VERSION + 1, 
 UPDATE_DATE = SYSDATE()
  WHERe    SLT_ACCOUNT_ID = #{sltAccountId} 
     AND VERSION = #{version}

简要说明:表设计时,需要往表里加一个version字段。每次查询时,查出带有version的数据记录,更新数据时,判断数据库里对应id的记录的version是否和查出的version相同。若相同,则更新数据并把版本号+1;若不同,则说明,该数据发送并发,被别的线程使用了,进行递归操作,再次执行递归方法,知道成功更新数据为止。

上述automaticAssign方法即实现了一个乐观锁,作用是冲数据库里更新一条数据病返回前端。如果并发率大,一次请求可能则会重复执行很多次automaticAssign,则性能低。如果并发很乐观,用户请求少,则不需要用synchronized,多线程时性能高。

在此只是简单说说,详细概念等需另行查阅相关资料。

更多java相关内容感兴趣的读者可查看本站专题:《Java面向对象程序设计入门与进阶教程》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》、《Java文件与目录操作技巧汇总》和《Java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/136491.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号