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