MySQL具有方便的功能:
SELECT GET_LOCK("SomeName")
这可用于为应用程序创建简单但非常具体的基于名称的锁。但是,它需要数据库连接。
我有很多情况,例如:
someMethod() { // do stuff to user A for their data for feature X }
简单地同步此方法是没有意义的,因为,例如,如果在此期间同时为用户B调用了此方法,则用户B无需等待用户A完成操作就可以开始操作,而只需为用户进行操作A和功能X的组合需要等待。
使用MySql锁,我可以执行以下操作:
someMethod() { executeQuery("SELECT GET_LOCK('userA-featureX')") // only locked for user A for their data for feature X executeQuery("SELECT RELEASE_LOCK('userA-featureX')") }
由于Java锁定基于对象,因此似乎需要创建一个新对象来表示此锁定的情况,然后将其放在某个位置的静态缓存中,以便所有线程都可以看到它。随后针对该情况进行锁定的请求将在高速缓存中定位锁定对象并获取其锁定。我试图创建类似这样的东西,但是锁缓存本身需要同步。而且,很难检测何时不再使用锁定对象,以便可以将其从缓存中删除。
我已经看过Java并发包,但是没有什么能够处理这样的事情了。有没有简单的方法可以实现此目的,还是我从错误的角度看待这个问题?
编辑:
为了明确起见,我不希望提前创建预定义的锁池,而是希望根据需要创建它们。我在想的一些伪代码是:
LockManager.acquireLock(String name) { Lock lock; synchronized (map) { lock = map.get(name); // doesn't exist yet - create and store if(lock == null) { lock = new Lock(); map.put(name, lock); } } lock.lock(); } LockManager.releaseLock(String name) { // unlock // if this was the last hold on the lock, remove it from the cache }
我看到的所有答案都太复杂了。为什么不简单使用:
public void executeInNamedLock(String lockName, Runnable runnable) { synchronized(lockName.intern()) { runnable.run(); } }
关键是方法intern:它确保返回的String是全局唯一对象,因此可以用作vm-instance-wide互斥量。所有的Interned Strings都保存在一个全局池中,因此这就是你在原始问题中所讨论的静态缓存。不用担心内存泄漏;如果没有其他线程引用这些字符串,则这些字符串将被gc’ed。但是请注意,直到(包括Java6)该池都保留在PermGen空间而不是堆中,因此你可能必须增加它。
intern
但是,如果vm中的某些其他代码由于完全不同的原因而锁定在同一字符串上,则会出现一个问题,但是a)这种可能性很小,b)你可以通过引入名称空间来解决它,例如 executeInNamedLock(this.getClass().getName() + "_" + myLockName);
executeInNamedLock(this.getClass().getName() + "_" + myLockName);