ArrayBlockingQueue add方法是即时的吗？

Question

对于Java中的ArrayBlockingQueue，does queue。添加（元素）是否锁定了它所在的线程？我有一个运行着数十个线程的应用程序，这些线程将所有信息放入一个ArrayBlockingQueue。线程无法承受任何短时间的锁定。如果他们都在将对象放入队列中，add方法会立即继续，让队列在将来将对象放入自己的队列中，还是等到对象实际放入队列中？

Answer 1

在ArrayBlockingQueue中，并发操作由java.util.concurrent.locks.ReentantLock保护。并且操作是同步的。当您将项目添加到队列时，添加操作在入列操作完成后返回。

Answer 2

是的，当您在ArrayBlockingQueue中调用add方法时，它将需要锁来执行操作，否则它将如何使线程安全。如何将您的对象放在多线程环境中的任何共享变量中。您需要同步。您可以检查一些非阻塞集合（可以创建自己的链表）。您将在其中添加您的值，然后一个守护程序线程将一个接一个地读取并放入队列。

JAVA实现

add方法内部调用offer。如果您不想等待超过给定时间，可以使用公共布尔tryLock（长超时，时间单位）

public boolean offer(E e) {
        checkNotNull(e);
        final ReentrantLock lock = this.lock;
        lock.lock();
        try {
            if (count == items.length)
                return false;
            else {
                enqueue(e);
                return true;
            }
        } finally {
            lock.unlock();
        }
    }

Answer 3

ArrayBlockingQueue是Queue的实现，它还支持在检索元素时等待队列变为非空，在存储元素时等待队列中的空间变为可用的操作。

如果可以在不超过队列容量的情况下立即在该队列的尾部插入指定的元素，add方法将在成功时返回true，如果该队列已满，则抛出IllegalStateException。

尝试将元素放入完整队列将导致操作阻塞；尝试从空队列中获取元素也会类似地阻塞。

一旦创建，容量就不能更改。