日韩一区二区在线观看,一区二区三区精品,超薄肉色丝袜一二三四区

等待遠(yuǎn)程redis lock肯定是需要一定重試機(jī)制，但是這種重試是需要一定的限制。

/** * 重試獲取鎖的次數(shù),可以根據(jù)當(dāng)前任務(wù)的執(zhí)行時(shí)間來設(shè)置。 * 需要時(shí)間=RetryCount*(WaitLockTimeSecond/1000) */ private static final int RetryCount = 10;

這種等待是需要用戶指定的， if (isWait && retryCounts < RetryCount) ，當(dāng)isWait為true才會(huì)進(jìn)行重試。

object.wait(timeout),條件隊(duì)列中的方法wait是需要一個(gè)waittime。

/** * 等待獲取鎖的時(shí)間，可以根據(jù)當(dāng)前任務(wù)的執(zhí)行時(shí)間來設(shè)置。 * 設(shè)置的太短，浪費(fèi)CPU，設(shè)置的太長(zhǎng)鎖就不太公平。 */ private static final long WaitLockTimeSecond = 2000;

long status = jedis.del(lockKey); if (status > 0) { logger.info(String. format(t:%s,當(dāng)前節(jié)點(diǎn)：%s,釋放鎖：%s 成功。, Thread.currentThread().getId(), getRedisIdentityKey(), lockKey)); return true; }

/** * 帶超時(shí)時(shí)間的redis lock. * * @param lockKeyExpireSecond 鎖key在redis中的過去時(shí)間 * @param lockKey lock key * @param isWait 當(dāng)獲取不到鎖時(shí)是否需要等待 * @throws Exception lockKey is empty throw exception. */ public Boolean acquireLockWithTimeout(int lockKeyExpireSecond, String lockKey, Boolean isWait) throws Exception { if (StringUtils.isEmpty(lockKey)) throw new Exception(lockKey is empty.); int retryCounts = 0; while (true) { Long status, expire = 0L; status = jedis.setnx(lockKey, redisIdentityKey);/**設(shè)置 lock key.*/ if (status > 0) { expire = jedis.expire(lockKey, lockKeyExpireSecond);/**set redis key expire time.*/ } if (status > 0 && expire > 0) { logger.info(String. format(t:%s,當(dāng)前節(jié)點(diǎn)：%s,獲取到鎖：%s, Thread.currentThread().getId(), getRedisIdentityKey(), lockKey)); return true;/**獲取到lock*/ } try { if (isWait && retryCounts < RetryCount) { retryCounts ; synchronized (this) {//借助object condition queue 來提高CPU利用率 logger.info(String. format(t:%s,當(dāng)前節(jié)點(diǎn)：%s,嘗試等待獲取鎖：%s, Thread.currentThread().getId(), getRedisIdentityKey(), lockKey)); this.wait(WaitLockTimeSecond); //未能獲取到lock，進(jìn)行指定時(shí)間的wait再重試. } } else if (retryCounts == RetryCount) { logger.info(String. format(t:%s,當(dāng)前節(jié)點(diǎn)：%s,指定時(shí)間內(nèi)獲取鎖失?。?s, Thread.currentThread().getId(), getRedisIdentityKey(), lockKey)); return false; } else { return false;//不需要等待，直接退出。 } } catch (InterruptedException e) { e.printStackTrace(); } } }

## release lock 釋放lock/** * 釋放redis lock。 * * @param lockKey lock key * @throws Exception lockKey is empty throw exception. */ public Boolean releaseLockWithTimeout(String lockKey) throws Exception { if (StringUtils.isEmpty(lockKey)) throw new Exception(lockKey is empty.); long status = jedis.del(lockKey); if (status > 0) { logger.info(String.format(當(dāng)前節(jié)點(diǎn)：%s,釋放鎖：%s 成功。, getRedisIdentityKey(), lockKey)); return true; } logger.info(String.format(當(dāng)前節(jié)點(diǎn)：%s,釋放鎖：%s 失敗。, getRedisIdentityKey(), lockKey)); return false; }

thread 23 優(yōu)先獲取到對(duì)商品ID 10100101 進(jìn)行修改，所以先鎖住當(dāng)前商品。

緊接著，thread 25也來對(duì)當(dāng)前商品 10100101進(jìn)行修改，所以在嘗試獲取鎖。

在進(jìn)行了retry10次（2000毫秒，2秒）之后，獲取失敗，直接返回，等待下次任務(wù)調(diào)度開始。

thread 28 發(fā)起對(duì)商品 10100101 進(jìn)行修改，retry6次之后獲取到lock。

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享網(wǎng)絡(luò)內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-62778877-8306；郵箱：fanjiao@west.cn。本站原創(chuàng)內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明出處：西部數(shù)碼知識(shí)庫 » redisLock redis分布式鎖

熱門搶注

熱門競(jìng)價(jià)

推薦一口價(jià)

猜你還會(huì)喜歡下面的內(nèi)容

熱門標(biāo)簽

大家感興趣的內(nèi)容

切換注冊(cè)登錄

切換登錄注冊(cè)