线程安全字段，避免读写冲突

Question

我正在尝试编写synccollection我在读写问题上崩溃了

我在每个线程中运行此代码

public void run() {
    for (int j = 0; j < threadElemAmount; j++) {
        list.remove((int) (list.size() - 1));
    }
}

方法内部的代码大小和运行

public T remove(int index){
    lock.lock();
    if (index >= size || index < 0)
        throw new IndexOutOfBoundsException("illegal index value, index = " + index + " size = " + size);
    T removedElement = (T) data[index];
    int movedElementsAmount = size - index - 1;
    //проверить кол-во перемещаемых элементов справа
    if (movedElementsAmount > 0) {
        System.arraycopy(data, index + 1, data, index, movedElementsAmount);
     }
     // очищаем последний
     data[--size] = null;
     lock.unlock();
     return removedElement;    
}

和尺寸

public int size() {
    lock.lock();
    int result = size;
    lock.unlock();
    return result; 
}

我不能使用synchronized关键字这是特殊情况的一部分，只是锁定，这几乎是一样的。因此，最弱的地方是list.size()调用和list.remove()调用之间的空间。如何避免读/写问题？

Answer 1

您需要为pop（）编写一个同步函数。

remove（index）很难替代线程安全的pop函数。

此外，您应该将代码更改为：

lock.lock()
try {
.
.
.
} finally {
    lock.unlock();
}

为了使其异常安全。

最后，但同样重要的是，size（）不需要同步。只需返回大小，因为它是只读操作。您可能想要使size参数不稳定，但在这里并不是特别需要。

Answer 2

您的选项是；

• 暴露锁，以便在两个选项中都可以保持它
• 与可见的锁同步使用
• 添加removeLast（）操作
• 添加drainTo（）操作
• 使用一个内置的线程安全集合，它已经完成了这项工作

看起来你想排出N个对象，所以最后一个选项可能是最好的。