带有 CompletableFuture 的 ReentrantLock

Question

在 CompletableFuture 世界之前，如果我想锁定一个变量，我可以这样做：

  private ReentrantLock myLock = new ReentrantLock();
  private List<UUID> myLockableList = new ArrayList<>();

  public void doStuff()
  {
    try
    {
      myLock.lock();
      myLockableList.clear();
    }
    finally
    {
      if (myLock.isLocked())
      {
        myLock.unlock();
      }
    }
  }

（显然，这是一个非常简化的示例，我也有其他方法尝试对 myLockableList 进行操作）。

根据 ReentrantLock，3 个场景中的 1 个会发生：

• 如果没有被其他线程持有，则获取锁并立即返回，将锁持有计数设置为 1
• 如果当前线程已经持有锁，那么持有计数加一并且方法立即返回
• 如果锁由另一个线程持有，则当前线程将出于线程调度目的而被禁用并处于休眠状态，直到获得锁为止，此时锁持有计数设置为 1。

这一切都很好，并且正是我期望它的行为：如果在同一个线程中工作，我应该知道我是否锁定了资源，如果另一个线程锁定了资源，我想等到它变得可用.

输入 CompletableFutures...

  private ReentrantLock myLock = new ReentrantLock();
  private List<UUID> myLockableList = new ArrayList<>();

  public CompletionStage<Void> doStuff()
  {
    return CompletableFuture.runAsync(() -> {
      try
      {
        myLock.lock();
        myLockableList.clear();
      }
      finally
      {
        if (myLock.isLocked())
        {
          myLock.unlock();
        }
      }
    });
  }

我希望 CompletableFuture 的行为是相同的。但是，A CompletableFuture 可能会使用新线程执行上述操作，或者（如果我的理解是正确的）它可能会使用已经在使用的线程。如果第二个发生（被重用的线程已经获得了锁），那么我的锁不会暂停线程并等待锁，相反，它实际上可能立即返回（看起来它已经获得了锁）！

我似乎无法在文档中找到明确的答案。我是否正确理解了情况？如果是这样，我们在使用 CompletableFuture 时应该如何锁定资源？

非常感谢您的建议！

Answer 1

除了 cmets 中推荐的 concurrency tutorial 之外，Javadoc for ReentrantLock 有很多值得一读的信息。

这个，例如：

ReentrantLock 归上次成功锁定但尚未解锁的线程所有。

您的示例使用isLocked()，Javadoc 说您不应该这样做：

此方法设计用于监控系统状态，而不是用于同步控制。

最后，Javadoc 包含一个很好的用法示例，在“try”块中显示lock()，然后在“finally”块中显示unlock()。

建议的做法是始终在调用 lock 之后立即使用 try 块，最常见的是在构造之前/之后，例如：

 class X {
   private final ReentrantLock lock = new ReentrantLock();
   // ...

   public void m() {
     lock.lock();  // block until condition holds
     try {
       // ... method body
     } finally {
       lock.unlock()
     }
   }
 }