快捷導(dǎo)航

java樂(lè)觀鎖原理與實(shí)現(xiàn)案例分析

更新時(shí)間：2019年10月31日 08:41:50 作者：zhangdehua678

這篇文章主要介紹了java樂(lè)觀鎖原理與實(shí)現(xiàn),結(jié)合具體案例形式分析了樂(lè)觀鎖的原理及java使用樂(lè)觀鎖實(shí)現(xiàn)自動(dòng)派單功能的相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了java樂(lè)觀鎖原理與實(shí)現(xiàn)。分享給大家供大家參考，具體如下：

簡(jiǎn)單說(shuō)說(shuō)樂(lè)觀鎖。樂(lè)觀鎖是相對(duì)于悲觀鎖而言。悲觀鎖認(rèn)為，這個(gè)線程，發(fā)生并發(fā)的可能性極大，線程沖突幾率大，比較悲觀。一般用synchronized實(shí)現(xiàn)，保證每次操作數(shù)據(jù)不會(huì)沖突。樂(lè)觀鎖認(rèn)為，線程沖突可能性小，比較樂(lè)觀，直接去操作數(shù)據(jù)，如果發(fā)現(xiàn)數(shù)據(jù)已經(jīng)被更改（通過(guò)版本號(hào)控制），則不更新數(shù)據(jù)，再次去重復(fù) 所需操作，知道沒有沖突（使用遞歸算法）。

因?yàn)闃?lè)觀鎖使用遞歸+版本號(hào)控制實(shí)現(xiàn)，所以，如果線程沖突幾率大，使用樂(lè)觀鎖會(huì)重復(fù)很多次操作（包括查詢數(shù)據(jù)庫(kù)），尤其是遞歸部分邏輯復(fù)雜，耗時(shí)和耗性能，是低效不合適的，應(yīng)考慮使用悲觀鎖。

樂(lè)觀鎖悲觀鎖的選擇：

樂(lè)觀鎖：并發(fā)沖突幾率小，對(duì)應(yīng)模塊遞歸操作簡(jiǎn)單時(shí)使用
悲觀鎖：并發(fā)幾率大，對(duì)應(yīng)模塊操作復(fù)雜時(shí)使用

下面給出一個(gè)樂(lè)觀鎖實(shí)例：

/**
 * 自動(dòng)派單
 * 只查出一條  返回list只是為了和查詢接口統(tǒng)一
 * 視頻審核訂單不派送
 * @param paramMap
 * @return
 */
public List<AutomaticAssignDto> automaticAssign(Map<String, Object> paramMap){
    //派送規(guī)則
    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; // 默認(rèn)先進(jìn)先審
        }
    }
    AutomaticAssignDto automaticAssignDto = new AutomaticAssignDto();
    automaticAssignDto.setChangeSortSet(changeSortSet);
    automaticAssignDto.setUserTeam(CommonUtils.getValue(paramMap, "userTeam"));
    List<AutomaticAssignDto> 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;
    }
}

對(duì)應(yīng)更新的sql：

<update id="bindAutomaticAssignInfo" parameterType="com.star.manager.dto.apply.AutomaticAssignDto">
  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}
</update>

簡(jiǎn)要說(shuō)明:表設(shè)計(jì)時(shí)，需要往表里加一個(gè)version字段。每次查詢時(shí)，查出帶有version的數(shù)據(jù)記錄，更新數(shù)據(jù)時(shí)，判斷數(shù)據(jù)庫(kù)里對(duì)應(yīng)id的記錄的version是否和查出的version相同。若相同，則更新數(shù)據(jù)并把版本號(hào)+1；若不同，則說(shuō)明，該數(shù)據(jù)發(fā)送并發(fā)，被別的線程使用了，進(jìn)行遞歸操作，再次執(zhí)行遞歸方法，知道成功更新數(shù)據(jù)為止。

上述automaticAssign方法即實(shí)現(xiàn)了一個(gè)樂(lè)觀鎖，作用是沖數(shù)據(jù)庫(kù)里更新一條數(shù)據(jù)病返回前端。如果并發(fā)率大，一次請(qǐng)求可能則會(huì)重復(fù)執(zhí)行很多次automaticAssign，則性能低。如果并發(fā)很樂(lè)觀，用戶請(qǐng)求少，則不需要用synchronized，多線程時(shí)性能高。

在此只是簡(jiǎn)單說(shuō)說(shuō)，詳細(xì)概念等需另行查閱相關(guān)資料。

更多java相關(guān)內(nèi)容感興趣的讀者可查看本站專題：《Java面向?qū)ο蟪绦蛟O(shè)計(jì)入門與進(jìn)階教程》、《Java數(shù)據(jù)結(jié)構(gòu)與算法教程》、《Java操作DOM節(jié)點(diǎn)技巧總結(jié)》、《Java文件與目錄操作技巧匯總》和《Java緩存操作技巧匯總》

希望本文所述對(duì)大家java程序設(shè)計(jì)有所幫助。

您可能感興趣的文章: