对 LinkedBlockingQueue 使用非线程安全列表

Question

我想知道如果我们将底层数据结构更改为像java.util.LinkedList 这样的非线程安全列表，为什么LinkedBlockingQueue 不能工作？当我尝试它时，我得到一个 NoSuchElementException。难道它没有被锁（takeLock）保护，这使它成为线程安全的吗？

private final List<E> list;
private final ReentrantLock takeLock;
private final ReentrantLock putLock;
private final Condition     notFull;
private final Condition     notEmpty;
private final AtomicInteger count;

public LinkedBlockingQueue() {
    takeLock = new ReentrantLock();
    putLock = new ReentrantLock();
    notFull = putLock.newCondition();
    notEmpty = takeLock.newCondition();
    count = new AtomicInteger(0);
    list = new LinkedList<E>();
}

public E get() {
   E item = null;
   int c = -1;
   try {
      takeLock.lockInterruptibly();
      while (count.get() == 0) notEmpty.await();

      // original -> item = dequeue();
      item = list.remove();   // NoSuchElementException

      c = count.getAndDecrement();
   } 
   catch (InterruptedException ie) {} 
   finally {
      takeLock.unlock();
   }

   if (c == capacity) signalNotFull();
   return item;
}

public void put(E e) {
   int c = -1;
   try {
      putLock.lockInterruptibly();
      while (count.get() == BOUND_SIZE) notFull.await();

      // original -> enqueue(node);
      list.add(e);

      c = count.getAndIncrement();
   } 
   catch (InterruptedException ie) {} 
   finally {
      putLock.unlock();
   }

   if (c == 0) signalNotEmpty();
}

Answer 1

您正在使用两个单独的锁定对象：

takeLock = new ReentrantLock();
putLock = new ReentrantLock();
notFull = putLock.newCondition();
notEmpty = takeLock.newCondition();

这是错误的。首先，您必须对 put 和 take 操作使用相同的锁对象。此外，您必须使用相同的锁定对象创建条件。

lock = new ReentrantLock();
notFull = lock.newCondition();
notEmpty = lock.newCondition();

你应该用给定的锁引用替换你的 takeLock 和 putLock 用法。

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/locks/Lock.html http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/locks/Condition.html