检查大小然后执行操作-ConcurrentLinkedDeque是否安全？

Question

Deque仅当大小将超过限制时，才需要用新值替换第一个值。我写了这段代码来解决它：

final class Some {

    final int buffer;

    final Deque<Operation> operations = new ConcurrentLinkedDeque<>();

    // constructors ommited;

    @Override

    public void register(final Operation operation) {

        if (this.operations.size() == this.buffer) {

            // remove the oldest operation

            this.operations.removeFirst();

        }

        // add new operation to the tail

        this.operations.addLast(operation);

    }

    @Override

    public void apply() {

        // take the fresh operation from tail and perform it

        this.operations.removeLast().perform();

    }

}

如您所见，我有两种方法可以修改Deque。我对此代码是否可以在多线程环境中正常运行感到怀疑。问题是：检查size()并随后执行修改ConcurrentLinkedDeque后的操作是否安全？我想要尽可能少的锁。因此，如果此代码行不通，那么我不得不引入锁定功能，那么使用毫无意义ConcurrentLinkedDeque()。

final class Some {

    final int buffer;

    final Deque<Operation> operations = new LinkedList<>();

    final Lock lock = new ReentrantLock();

    // constructors ommited;

    @Override

    public void register(final Operation operation) {

        this.lock.lock();

        try {

            if (this.operations.size() == this.buffer) {

                // remove the oldest operation

                this.operations.removeFirst();

            }

            // add new operation to the tail

            this.operations.addLast(operation);

        } finally {

            lock.unlock();

        }

    }

    @Override

    public void apply() {

        this.lock.lock();

        try {

            // take the fresh operation from tail and perform it

            this.operations.removeLast().perform();

        } finally {

            this.lock.unlock();

        }

    }

}

这是的替代选择Lock。那是实现我想要的唯一途径吗？我对尝试使用并发集合特别感兴趣。

Answer 1

从文档的size（）注意，与大多数集合不同，此方法不是恒定时间操作。由于这些双端队列的异步性质，确定当前元素数量需要遍历所有元素以进行计数。此外，在执行此方法期间大小可能会更改，在这种情况下，返回的结果将不准确。因此，该方法在并发应用程序中通常不是很有用。尽管@Slaw是正确的，但还请注意，遍历过程中可能会发生加法/减法。我不在软件中使用size（）。我使用AtomicInteger自己计算集合中的内容。如果count.get（）<max，我可以添加。对于我的使用来说，最大超出一点是可以的。您可以使用计数锁定来强制遵从。