|
|
@ -43,13 +43,6 @@ public class RedissonRedLockTest {
|
|
|
|
public void run() {
|
|
|
|
public void run() {
|
|
|
|
RedissonMultiLock lock = new RedissonRedLock(lock1, lock2, lock3);
|
|
|
|
RedissonMultiLock lock = new RedissonRedLock(lock1, lock2, lock3);
|
|
|
|
lock.lock();
|
|
|
|
lock.lock();
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
|
|
|
Thread.sleep(3000);
|
|
|
|
|
|
|
|
} catch (InterruptedException e) {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
lock.unlock();
|
|
|
|
|
|
|
|
};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
t.start();
|
|
|
|
t.start();
|
|
|
@ -92,13 +85,14 @@ public class RedissonRedLockTest {
|
|
|
|
Thread.sleep(3000);
|
|
|
|
Thread.sleep(3000);
|
|
|
|
} catch (InterruptedException e) {
|
|
|
|
} catch (InterruptedException e) {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
lock.unlock();
|
|
|
|
lock.unlock();
|
|
|
|
};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
};
|
|
|
|
t.start();
|
|
|
|
t.start();
|
|
|
|
t.join(1000);
|
|
|
|
t.join(1000);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
lock3.delete();
|
|
|
|
|
|
|
|
|
|
|
|
RedissonMultiLock lock = new RedissonRedLock(lock1, lock2, lock3);
|
|
|
|
RedissonMultiLock lock = new RedissonRedLock(lock1, lock2, lock3);
|
|
|
|
lock.lock();
|
|
|
|
lock.lock();
|
|
|
|
lock.unlock();
|
|
|
|
lock.unlock();
|
|
|
|