是否有一個讀監聽器的Java寫鎖？

Question

是否有一個java庫實現的行爲類似於ReadWriteLock，但使用偵聽器或CompletableFuture/CompletionStage而不是阻塞？

理想我想這樣寫：

lock = ... 

CompletionStage stage = lock.lockRead(); 
stage.thenAccept(r -> { doSomething(); r.release(); }); 

而且也很重要：

CompletionStage stage = lock.tryLockWrite(10, TimeUnit.SECONDS); 
stage.handle(callback); 

---

我希望知道，如果這樣的事情存在，如果它確實如何它叫做。

我不想自己實現這個，而是使用庫來簡化一些框架代碼。

Answer 1

我覺得自己寫就不應該夠難。有機會比尋找圖書館花費更少的時間。這是很簡單的整體：

static const int STATE_UNLOCKED = 0; 
static const int STATE_READING = 1; 
static const int STATE_WRITING = 2; 
int state = STATE_UNLOCKED; 
int readers = 0; 
Queue<CompletableFuture<Void>> queueWriters = new LinkedList<CompletableFuture<Void>>(); 
Queue<CompletableFuture<Void>> queueReaders = new LinkedList<CompletableFuture<Void>>(); 

public synchronized CompletionStage<Void> lockWriter() { 
    CompletableFuture<Void> l = new CompletableFuture<Void>(); 
    if (state == STATE_UNLOCKED) { 
     state = STATE_WRITING; 
     l.complete(null); 
     return l; 
    } 
    queueWriters.offer(l); 
    return l; 
} 

public synchronized CompletionStage<Void> lockReader() { 
    CompletableFuture<Void> l = new CompletableFuture<Void>(); 
    if (state != STATE_WRITING) { 
     state = STATE_READING; 
     readers++; 
     l.complete(null); 
     return l; 
    } 
    queueReaders.offer(l); 
    return l; 
} 

public void unlock() { 
    CompletableFuture<Void> l = null; 
    synchronized(this) { 
     if (state == STATE_READING) { 
      readers--; 
      if (readers > 0) { 
       return; 
      } 
     } 
     l = queueReaders.poll(); 
     if (l != null) { 
      state = STATE_READING; 
      readers++; 
     } 
     else { 
      l = queueWriters.poll(); 
      if (l != null) { 
       state = STATE_WRITING; 
      } 
      else { 
       state = STATE_UNLOCKED; 
       return; 
      } 
     } 
    } 
    l.complete(null); 
    while (true) { 
     synchronized (this) { 
      if (state != STATE_READING) { 
       return; 
      } 
      l = queueReaders.poll(); 
      if (l == null) { 
       return; 
      } 
      readers++; 
     } 
     l.complete(null); 
    } 
} 

添加定時鎖定（通過使用某種形式的「到期隊列」或作家飢餓預防（通過防止更多的讀者從如果queueWriters不爲空，正在執行）以上不應該