ReentrantLock 和 Condition 变量

Question

你好:) 我正在学习 Java 中的重入锁和条件变量。我碰巧遇到了这个tutorial。在教程中，作者提供了一个利用 ReentrantLock 的 Producer-Consumer 示例：

public class CondDemo
{
   public static void main(String[] args)
   {
      Shared s = new Shared();
      new Producer(s).start();
      new Consumer(s).start();
   }
}

class Shared
{
   private volatile char c;
   private volatile boolean available;
   private final Lock lock;
   private final Condition condition;

   Shared()
   {
      c = '\u0000';
      available = false;
      lock = new ReentrantLock();
      condition = lock.newCondition();
   }

   Lock getLock()
   {
      return lock;
   }

   char getSharedChar()
   {
      lock.lock();
      try
      {
         while (!available) {
            try
            {
               condition.await();
            }
            catch (InterruptedException ie)
            {
               ie.printStackTrace();
            }
         }
         available = false;
         condition.signal();
      }
      finally
      {
         lock.unlock();
         return c;
      }
   }

   void setSharedChar(char c)
   {
      lock.lock();
      try
      {
         while (available) {
            try
            {
               condition.await();
            }
            catch (InterruptedException ie)
            {
               ie.printStackTrace();
            }
         }
         this.c = c;
         available = true;
         condition.signal();
      }
      finally
      {
         lock.unlock();
      }
   }
}

class Producer extends Thread
{
   private final Lock l;

   private final Shared s;

   Producer(Shared s)
   {
      this.s = s;
      l = s.getLock();
   }

   @Override
   public void run()
   {
      for (char ch = 'A'; ch <= 'Z'; ch++)
      {
         l.lock();
         s.setSharedChar(ch);
         System.out.println(ch + " produced by producer.");
         l.unlock();
      }
   }
}

class Consumer extends Thread
{
   private final Lock l;

   private final Shared s;

   Consumer(Shared s)
   {
      this.s = s;
      l = s.getLock();
   }

   @Override
   public void run()
   {
      char ch;
      do
      {
         l.lock();
         ch = s.getSharedChar();
         System.out.println(ch + " consumed by consumer.");
         l.unlock();
      }
      while (ch != 'Z');
   }
}

Producer 和 Consumer 中的 l.lock() 和 l.unlock() 方法是不必要的吗？我注意到我们已经在Shared 对象的getSharedChar() 和setSharedChar() 方法中应用了锁定/解锁。或者这是使用条件变量的建议模式？

这是一个不好的做法，你能提供一个更好的例子的链接吗？

谢谢:)

Answer 1

这既不是必需的，也不是模式。

恕我直言，这是一个丑陋的冗余锁，曾经有干净的输出。我的意思是丑陋，因为没有 try-finally 来确保第一级解锁并且它暴露了Shared API 的内部状态。

要深入学习Java并发，你可以使用SynchronousQueue或Exchanger获得相同的结果