您好,登錄后才能下訂單哦!
本文實例講述了java樂觀鎖原理與實現。分享給大家供大家參考,具體如下:
簡單說說樂觀鎖。樂觀鎖是相對于悲觀鎖而言。悲觀鎖認為,這個線程,發生并發的可能性極大,線程沖突幾率大,比較悲觀。一般用synchronized實現,保證每次操作數據不會沖突。樂觀鎖認為,線程沖突可能性小,比較樂觀,直接去操作數據,如果發現數據已經被更改(通過版本號控制),則不更新數據,再次去重復 所需操作,知道沒有沖突(使用遞歸算法)。
因為樂觀鎖使用遞歸+版本號控制 實現,所以,如果線程沖突幾率大,使用樂觀鎖會重復很多次操作(包括查詢數據庫),尤其是遞歸部分邏輯復雜,耗時和耗性能,是低效不合適的,應考慮使用悲觀鎖。
樂觀鎖悲觀鎖的選擇:
下面給出一個樂觀鎖實例:
/** * 自動派單 * 只查出一條 返回list只是為了和查詢接口統一 * 視頻審核訂單不派送 * @param paramMap * @return */ public List<AutomaticAssignDto> automaticAssign(Map<String, Object> 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<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; } }
對應更新的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>
簡要說明:表設計時,需要往表里加一個version字段。每次查詢時,查出帶有version的數據記錄,更新數據時,判斷數據庫里對應id的記錄的version是否和查出的version相同。若相同,則更新數據并把版本號+1;若不同,則說明,該數據發送并發,被別的線程使用了,進行遞歸操作,再次執行遞歸方法,知道成功更新數據為止。
上述automaticAssign方法即實現了一個樂觀鎖,作用是沖數據庫里更新一條數據病返回前端。如果并發率大,一次請求可能則會重復執行很多次automaticAssign,則性能低。如果并發很樂觀,用戶請求少,則不需要用synchronized,多線程時性能高。
在此只是簡單說說,詳細概念等需另行查閱相關資料。
更多java相關內容感興趣的讀者可查看本站專題:《Java面向對象程序設計入門與進階教程》、《Java數據結構與算法教程》、《Java操作DOM節點技巧總結》、《Java文件與目錄操作技巧匯總》和《Java緩存操作技巧匯總》
希望本文所述對大家java程序設計有所幫助。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。