是否有我可以使用的不可重入读写库？

Question

我需要一个不可重入的读写锁，因为锁可能由获取它的线程以外的线程释放。（我意识到这一点时，我开始间歇性地获取非法监视器状态异常。）

我不确定不可重入是否是正确的术语。ReentrantLock允许当前持有锁的线程再次获取它。我不想要这种行为，因此我称之为“不可重入”。

上下文是我有一个使用线程池的套接字服务器。每个连接没有一个线程。请求可能由不同的线程处理。客户端连接可能需要在一个请求中锁定，在另一个请求中解锁。由于请求可能由不同的线程处理，因此我需要能够在不同的线程中锁定和解锁。

为了回答这个问题，假设我需要继续使用这个配置，并且我确实需要在不同的请求中锁定和解锁，因此可能需要不同的线程。

这是一个读写锁，因为我需要允许多个“读者”或一个独家“作家”。

这看起来像是可以使用AbstractQueuedSynChronzer编写的，但是我担心如果我自己编写，我会犯一些微妙的错误。我可以找到各种使用AbstractQueuedSynChronzer的例子，但不是ReadWriteLock。

我可以使用OpenJDK ReentrantReadWriteLock源代码并尝试删除可重入部分，但我担心我不会完全正确。

我在番石榴和阿帕奇公地找过了，但没有找到任何合适的。Apache Commons有RWLockManager，它可能会做我需要的，但我不确定，它似乎比我需要的更复杂。

Answer 1

不完全确定您需要什么，特别是为什么它应该是一个读写锁，但如果您有需要由多个线程处理的任务，并且您不希望它被并发处理/访问，我实际上会使用ConcurrentMap（等等）。

您可以从映射中删除任务，或者用特殊的“锁定对象”替换它，以指示它已锁定。您可以将具有更新状态的任务返回到映射以让另一个线程接管，或者您也可以将任务直接传递给下一个线程，让它将任务返回到映射。

Answer 2

我知道你已经接受了另一个答案。但我仍然认为你会给自己制造一场噩梦。最终，客户将无法返回并发布这些许可证，您将开始纳闷为什么“作者”从不写作。

如果我这样做，我会这样做：

Client issues a request to start a transaction
The initial request creates a task (Runnable/Callable) and places it in an Executor for execution
The initial request also registers that task in a Map by transaction id

Client issues the second request to close the transaction
The close request finds the task by transaction id in a map
The close request calls a method on the task to indicate that it should close (probably a signal on a Condition or if data needs to be passed, placing an object in a BlockingQueue)

现在，事务任务的代码如下：

public void run() {
    readWriteLock.readLock().lock();
    try {
        //do stuff for initializing this transaction
        if (condition.await(someDurationAsLong, someTimeUnit)( {
            //do the rest of the transaction stuff
        } else {
            //do some other stuff to back out the transaction
        }
    } finally {
        readWriteLock.readLock.unlock();
    }
}

Answer 3

信号量允许不同的线程执行许可的获取和释放。独占写入相当于拥有所有许可证，因为线程会等待所有许可证都被释放，其他线程无法获得额外的许可证。

final int PERMITS = Integer.MAX_VALUE;
Semaphore semaphore = new Semaphore(PERMITS);

// read
semaphore.acquire(1);
try { ... }
finally {
  semaphore.release(1);
}

// write
semaphore.acquire(PERMITS);
try { ... }
finally {
  semaphore.release(PERMITS);
}