|
@@ -25,7 +25,7 @@ public class LockService implements InitializingBean, ApplicationContextAware {
|
|
|
|
|
|
/**
|
|
/**
|
|
* 尝试获取排他锁,立即返回获取结果
|
|
* 尝试获取排他锁,立即返回获取结果
|
|
- *
|
|
|
|
|
|
+ *
|
|
* @param type
|
|
* @param type
|
|
* @param keys
|
|
* @param keys
|
|
* @return
|
|
* @return
|
|
@@ -36,7 +36,7 @@ public class LockService implements InitializingBean, ApplicationContextAware {
|
|
|
|
|
|
/**
|
|
/**
|
|
* 等待获取排他锁,线程阻塞直到成功获取
|
|
* 等待获取排他锁,线程阻塞直到成功获取
|
|
- *
|
|
|
|
|
|
+ *
|
|
* @param type
|
|
* @param type
|
|
* @param keys
|
|
* @param keys
|
|
*/
|
|
*/
|
|
@@ -45,9 +45,8 @@ public class LockService implements InitializingBean, ApplicationContextAware {
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- *
|
|
|
|
* 释放已获取的排他锁
|
|
* 释放已获取的排他锁
|
|
- *
|
|
|
|
|
|
+ *
|
|
* @param type
|
|
* @param type
|
|
* @param keys
|
|
* @param keys
|
|
*/
|
|
*/
|
|
@@ -57,7 +56,7 @@ public class LockService implements InitializingBean, ApplicationContextAware {
|
|
|
|
|
|
/**
|
|
/**
|
|
* 检测排他锁是否已被获取
|
|
* 检测排他锁是否已被获取
|
|
- *
|
|
|
|
|
|
+ *
|
|
* @param type
|
|
* @param type
|
|
* @param keys
|
|
* @param keys
|
|
* @return
|
|
* @return
|
|
@@ -68,23 +67,22 @@ public class LockService implements InitializingBean, ApplicationContextAware {
|
|
|
|
|
|
/**
|
|
/**
|
|
* 等待获取可重入的读锁
|
|
* 等待获取可重入的读锁
|
|
- *
|
|
|
|
|
|
+ *
|
|
* @param type
|
|
* @param type
|
|
* @param keys
|
|
* @param keys
|
|
*/
|
|
*/
|
|
public void watch(LockType type, Object... keys) {
|
|
public void watch(LockType type, Object... keys) {
|
|
- provider.waitLock(type, getKeys(keys));
|
|
|
|
|
|
+ provider.watch(type, getKeys(keys));
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|
|
- *
|
|
|
|
* 释放已获取的读锁
|
|
* 释放已获取的读锁
|
|
- *
|
|
|
|
|
|
+ *
|
|
* @param type
|
|
* @param type
|
|
* @param keys
|
|
* @param keys
|
|
*/
|
|
*/
|
|
public void unwatch(LockType type, Object... keys) {
|
|
public void unwatch(LockType type, Object... keys) {
|
|
- provider.unlock(type, getKeys(keys));
|
|
|
|
|
|
+ provider.unwatch(type, getKeys(keys));
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
/**
|