我有一个LockManager,它管理多个线程的锁。有时线程是坏男孩,我不得不杀了他们,并要求LockManager释放他们的所有锁。但是,由于我在java中使用ReentrantLock,这是不可能的,所以我无法解除另一个线程拥有的锁。
我被迫使用锁(不能使用信号量,这是作业的要点)。是否有任何Java实现允许我解锁其他线程拥有的锁?
到目前为止,我所考虑的选择是:
你可能会发现额外的资源是有用的:
发布于 2013-05-10 23:41:39
你可以使用你自己的Lock
吗?下面是一个完全代理Lock
的类,但是当它被告知强制解锁时,它只是替换锁,它用一个新的锁进行代理。这应该有你想要的效果。可悲的是,它仍然没有处理剩下的锁,但现在这变成了其他人的问题。你的锁现在被魔法解锁了。
static class LockProxy<L extends Lock> implements Lock {
// The actual lock.
private volatile Lock lock;
public LockProxy(L lock) {
// Trap the lock we are proxying.
this.lock = lock;
}
@Override
public void lock() {
// Proxy it.
lock.lock();
}
@Override
public void lockInterruptibly() throws InterruptedException {
// Proxy it.
lock.lockInterruptibly();
}
@Override
public boolean tryLock() {
// Proxy it.
return lock.tryLock();
}
@Override
public boolean tryLock(long l, TimeUnit tu) throws InterruptedException {
// Proxy it.
return lock.tryLock(l, tu);
}
@Override
public void unlock() {
// Proxy it.
lock.unlock();
}
@Override
public Condition newCondition() {
// Proxy it.
return lock.newCondition();
}
// Extra functionality to unlock from any thread.
public void forceUnlock() {
// Actually just replace the perhaps locked lock with a new one.
// Kinda like a clone. I expect a neater way is around somewhere.
if (lock instanceof ReentrantLock) {
lock = new ReentrantLock();
} else {
throw new UnsupportedOperationException(
"Cannot force unlock of lock type "
+ lock.getClass().getSimpleName());
}
}
}
发布于 2013-05-10 21:58:58
你已经发现了一个主要的原因,为什么普通的智慧说:不要杀死线程!
如果强行关闭线程,锁只是可能发生的资源泄漏之一。考虑打开文件和套接字等。
还请考虑,如果您确实设法解除锁,有一个原因,锁被锁定在第一。例如,线程可能已经部分更新了数据结构,并且允许从另一个线程访问该结构可能会导致奇怪和奇妙的程序故障,这些程序故障很难调试,甚至不可能调试。
处理这种情况的最好方法是让线程走开。向与线程关联的对象中添加一个“to ()”方法(每个线程都有一个对象,不是吗?)这将设置一个标志,并让线程定期检查此标志,并在设置该标志时退出。
如果您的线程行为不当,从而阻止它们检查停止标志,那么正确的方法是修复代码,使其不出现错误行为。
发布于 2019-05-02 22:12:54
我用AtomicReference做了这件事,它在优雅方面得到了零分,但我不知道还有什么别的方法。
class PseudoLock {
private final AtomicReference<Boolean> mylock = new AtomicReference<>(Boolean.FALSE);
boolean trylock() {
return mylock.compareAndSet(Boolean.FALSE, Boolean.TRUE);
}
void unlock() {
boolean done = mylock.compareAndSet(Boolean.TRUE, Boolean.FALSE);
if (!done) {
throw new IllegalStateException("Cannot unlock an unlocked thread");
}
}
}
“
https://stackoverflow.com/questions/16491287
复制相似问题