其他分享
首页 > 其他分享> > 什么是死锁,以及代码

什么是死锁,以及代码

作者:互联网

private LockUtils(){
}

public static boolean lock(String lockName){//lockName可以为共享变量名,也可以为方法名,主要是用于模拟锁信息
    System.out.println(Thread.currentThread() + "开始尝试加锁!");
    Long result = RedisPoolUtil.setnx(lockName, String.valueOf(System.currentTimeMillis() + 5000));
    //setnx这个操作成功并且返回1,表示这个锁没有被别人获取,如果锁在别人手上则会返回0
    if (result != null && result.intValue() == 1){
        System.out.println(Thread.currentThread() + "加锁成功!");
        RedisPoolUtil.expire(lockName, 5);
        System.out.println(Thread.currentThread() + "执行业务逻辑!");
        RedisPoolUtil.del(lockName);
        return true;
    } else { 
    //这里的走向主要判断锁还在被别的线程持有,而且持有的时间已经超过所设置的过期时间。
    //否则表示这把锁已经被人拿走了,因为这里的走向代表返回的不是1
    	//通过key查询value(这个value代表上一个线程持锁线程的时间戳)	
        String lockValueA = RedisPoolUtil.get(lockName);
        //当前时间大于所设置时间戳,表示锁的时间已经过期了
        if (System.currentTimeMillis() >= (lockValueA != null && Long.parseLong(lockValueA)) ){
        //如果锁已经过期了说明锁失效了,就可以重新获取锁,通过getset重新设置时间戳,并且返回上一个持锁线程的时间戳lockValueB
            String lockValueB = RedisPoolUtil.getSet(lockName, String.valueOf(System.currentTimeMillis() + 5000));
            //如果lockValueB !=lockValueA,代表lockValue在getset之前有一条线程已经拿走锁了,然后重新设置了时间戳,所以导致现在这条线程拿到的时间戳和lockValueA对不上。
            if (lockValueB == null || lockValueB.equals(lockValueA)){
                System.out.println(Thread.currentThread() + "加锁成功!");
                RedisPoolUtil.expire(lockName, 5);
                System.out.println(Thread.currentThread() + "执行业务逻辑!");
                RedisPoolUtil.del(lockName);
                return true;
            } else {
                return false;
            }
        } else {
            return false;
        }
    }
}
1

  参考:

(64条消息) Redis分布式锁实现以及避免死锁_qq_40925755的博客-CSDN博客_redis避免死锁

标签:lockName,Thread,以及,代码,System,死锁,lockValueA,println,RedisPoolUtil
来源: https://www.cnblogs.com/wuqihe/p/16332543.html