免费视频淫片aa毛片_日韩高清在线亚洲专区vr_日韩大片免费观看视频播放_亚洲欧美国产精品完整版

你知道的越多，不知道的就越多，業(yè)余的像一棵小草！

編輯：業(yè)余草

來(lái)源：https://urlify.cn/632yIv

推薦：https://www.xttblog.com/?p=5035

配置信息

spring:
# redis
  redis:
    host: 47.103.5.190
    port: 6379
    jedis:
      pool:
# 連接池最大連接數(shù)（使用負(fù)值表示沒(méi)有限制）
        max-active: 100
# 連接池中的最小空閑連接
        max-idle: 10
# 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒(méi)有限制）
        max-wait: -1
# 連接超時(shí)時(shí)間（毫秒）
      timeout: 5000
#默認(rèn)是索引為0的數(shù)據(jù)庫(kù)
      database: 0

配置類

Redisson 工具類

/**
 * redis分布式鎖幫助類
 *
 * @author gourd
 *
 */
publicclassRedisLockUtil{
privatestaticDistributedLocker distributedLocker = SpringContextHolder.getBean('distributedLocker',DistributedLocker.class);
/**
     * 加鎖
     * @param lockKey
     * @return
     */
publicstaticRLocklock(String lockKey) {
return distributedLocker.lock(lockKey);
}
/**
     * 釋放鎖
     * @param lockKey
     */
publicstaticvoid unlock(String lockKey) {
        distributedLocker.unlock(lockKey);
}
/**
     * 釋放鎖
     * @param lock
     */
publicstaticvoid unlock(RLocklock) {
        distributedLocker.unlock(lock);
}
/**
     * 帶超時(shí)的鎖
     * @param lockKey
     * @param timeout 超時(shí)時(shí)間   單位：秒
     */
publicstaticRLocklock(String lockKey, int timeout) {
return distributedLocker.lock(lockKey, timeout);
}
/**
     * 帶超時(shí)的鎖
     * @param lockKey
     * @param unit 時(shí)間單位
     * @param timeout 超時(shí)時(shí)間
     */
publicstaticRLocklock(String lockKey, int timeout,TimeUnit unit ) {
return distributedLocker.lock(lockKey, unit, timeout);
}
/**
     * 嘗試獲取鎖
     * @param lockKey
     * @param waitTime 最多等待時(shí)間
     * @param leaseTime 上鎖后自動(dòng)釋放鎖時(shí)間
     * @return
     */
publicstaticboolean tryLock(String lockKey, int waitTime, int leaseTime) {
return distributedLocker.tryLock(lockKey, TimeUnit.SECONDS, waitTime, leaseTime);
}
/**
     * 嘗試獲取鎖
     * @param lockKey
     * @param unit 時(shí)間單位
     * @param waitTime 最多等待時(shí)間
     * @param leaseTime 上鎖后自動(dòng)釋放鎖時(shí)間
     * @return
     */
publicstaticboolean tryLock(String lockKey, TimeUnit unit, int waitTime, int leaseTime) {
return distributedLocker.tryLock(lockKey, unit, waitTime, leaseTime);
}
/**
     * 獲取計(jì)數(shù)器
     *
     * @param name
     * @return
     */
publicstaticRCountDownLatch getCountDownLatch(String name){
return distributedLocker.getCountDownLatch(name);
}
/**
     * 獲取信號(hào)量
     *
     * @param name
     * @return
     */
publicstaticRSemaphore getSemaphore(String name){
return distributedLocker.getSemaphore(name);
}
}

底層封裝

/**
 * redis分布式鎖控制器
 * @author gourd
 * @since 2019-07-30
 */
@RestController
@Api(tags = 'redisson', description = 'redis分布式鎖控制器')
@RequestMapping('/redisson')
@Slf4j
publicclassRedissonLockController{
/**
     * 鎖測(cè)試共享變量
     */
privateInteger lockCount = 10;
/**
     * 無(wú)鎖測(cè)試共享變量
     */
privateInteger count = 10;
/**
     * 模擬線程數(shù)
     */
privatestaticint threadNum = 10;
/**
     * 模擬并發(fā)測(cè)試加鎖和不加鎖
     * @return
     */
@GetMapping('/test')
@ApiOperation(value = '模擬并發(fā)測(cè)試加鎖和不加鎖')
publicvoidlock(){
// 計(jì)數(shù)器
finalCountDownLatch countDownLatch = newCountDownLatch(1);
for(int i = 0; i < threadNum; i ++) {
MyRunnable myRunnable = newMyRunnable(countDownLatch);
Thread myThread = newThread(myRunnable);
            myThread.start();
}
// 釋放所有線程
        countDownLatch.countDown();
}
/**
     * 加鎖測(cè)試
     */
privatevoid testLockCount() {
String lockKey = 'lock-test';
try{
// 加鎖，設(shè)置超時(shí)時(shí)間2s
RedisLockUtil.lock(lockKey,2, TimeUnit.SECONDS);
            lockCount--;
            log.info('lockCount值：'+lockCount);
}catch(Exception e){
            log.error(e.getMessage(),e);
}finally{
// 釋放鎖
RedisLockUtil.unlock(lockKey);
}
}
/**
     * 無(wú)鎖測(cè)試
     */
privatevoid testCount() {
        count--;
        log.info('count值：'+count);
}
publicclassMyRunnableimplementsRunnable{
/**
         * 計(jì)數(shù)器
         */
finalCountDownLatch countDownLatch;
publicMyRunnable(CountDownLatch countDownLatch) {
this.countDownLatch = countDownLatch;
}
@Override
publicvoid run() {
try{
// 阻塞當(dāng)前線程，直到計(jì)時(shí)器的值為0
                countDownLatch.await();
} catch(InterruptedException e) {
                log.error(e.getMessage(),e);
}
// 無(wú)鎖操作
            testCount();
// 加鎖操作
            testLockCount();
}
}
}

調(diào)用接口后打印值：