我正在尝试编写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;
}


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

最佳答案

您需要为pop()写一个同步函数。

remove(index)不能很好地替代线程安全的弹出函数。

另外,您应该将代码更改为:

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


为了使其异常安全。

最后但并非最不重要的一点是,size()不需要同步。因为它是只读操作,所以只需返回大小即可。您可能想使size参数可变,但是在这里并不是特别必要。

关于java - 线程安全字段,避免读写冲突,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/33854149/

10-11 22:37
查看更多