appleappleapple / distributelearning Goto Github PK

Contributors

Stargazers

Forkers

oniubi sentenes longxian435 houyi1024 garyfub huangleisir yeyinzhu321 409696598 smallleaf duxingzhe311 conkeyn jjjuin superpigluker justin20171102 wangzhentang supermariox drtjordan kojz jia4tin bickshaw tshaozhang swidy360 imqbing zhonghuaxiaodangjia liubin192837 yangchunjian jibaro langhsu liangzhenghui wuzedong lmh-din zhengzhenmu huanghaiheart wenwu1114 lllsy1997 javacodemood dololitingyu skyinbj maidouerer a9b9a9b9a9 mialiyimi classloader ian1002 zzmlover jackyyueng sleepguo yuan-wei liangzi0319 linyichang luojian220 qs86123 chengguruchun lxlx704034204 t0mac cuilike xlzwhboy xiaofengjingbo jason-learn mrwangsoul ervinyang tw0629 zhc8844096 kevinyzy1 thaiyang2009 atbeginheart iwordz coolmoongg zehuihuang zql3315 wwwguiguigui zengwh1993 qcghdy yuwenxing mr-zbh elephanyu javaforstudy jijia128 zyq11223 fadedaway wl199601 446066740 n040661 wukejiong shesunshine yeahlow cztong qiuliliang xuliugen prayjourney jadeluo xujian01 lhsmysins bigdemage jibowang w0807c zuoliguang jvonneumann going-screech93 glumffff

		String stringOfLockExpireTime = String.valueOf(lockExpireTime);

		System.out.println("test4");
		if (jedis.setnx(lockKey, stringOfLockExpireTime) == 1) { // 获取到锁
			System.out.println("test5");
			//成功获取到锁, 设置相关标识
			locked = true;
			setExclusiveOwnerThread(Thread.currentThread());
			return true;
		}

		System.out.println("test6");
		String value = jedis.get(lockKey);
		if (value != null && isTimeExpired(value)) { // lock is expired
			System.out.println("test7");
			// 假设多个线程(非单jvm)同时走到这里
			String oldValue = jedis.getSet(lockKey, stringOfLockExpireTime); //原子操作
			// 但是走到这里时每个线程拿到的oldValue肯定不可能一样(因为getset是原子性的)
			// 加入拿到的oldValue依然是expired的，那么就说明拿到锁了