Как блокировка будет вести себя в .net?
abstract class Foo
{
private List<Object> container;
private bool update;
Foo Foo()
{
container = new List<object>();
update = false;
}
public abstract Bar CreateBar();
public void BeginUpdate()
{
if (!update)
{
Thread update_thread = new Thread(new ThreadStart(Update));
update_thread.Start();
}
}
private void Update()
{
update = true;
while (update)
{
lock (container)
{
if (...)
container.Add(this.CreateBar());
else
container.Remove(...);
}
Thread.Sleep(1337);
}
}
public void EndUpdate()
{
update = false;
}
public List<Object> Objects
{
get
{
lock (container)
{
return this.container;
}
}
}
}
Когда что-то за пределами Foo вызывает метод доступа к объекту Foo, например,
List<Objects> objects = foo_instance.Objects;
foreach (Object o in objects)
{
Thread.Sleep(31173);
}
Как будет происходить блокировка? Придется ли потоку, выполняющему Update (), ждать, пока приведенный выше foreach не завершит обработку списка объектов? Я бы хотел, чтобы эти два работали одновременно, разве это единственное решение для создания глубокой копии объектов?
Ответы 4
Вы можете думать о области блокировки, как о области действия. Выполнение блокировки внутри вашего метода доступа приведет к блокировке только между фигурными скобками, после того как значение будет возвращено, блокировка будет снята. Вам нужно будет выполнить блокировку вне класса (в вызывающей программе), чтобы получить желаемый эффект.
Таким образом, и цикл, и поток будут иметь доступ к объектам одновременно. Это плохо, потому что, если ваш поток изменяет объекты во время цикла, цикл выдаст исключение, потому что коллекция была изменена.
Ваш код не делает того, что вы думаете. Этот метод
public List<Object> Objects
{
get
{
lock (container)
{
return this.container;
}
}
}
Не удерживает блокировку после возврата значения. Итак, ваш цикл не заблокирован.
Вы не можете вернуть экземпляр контейнера из класса
Несколько проблем с этим кодом:
- Вы не начинаете тред
- У вас может быть состояние гонки (может быть неприменимо к вашей программе), когда несколько потоков вызывают BeginUpdate, оба видят, что обновление ложно, и оба запускают поток, теперь у вас есть два запущенных потока, возможно, мешающих друг другу, поскольку вы иметь полевой член с общими данными
- В чем смысл блокировки собственности? Тебе это не нужно. Обратите внимание, что контейнер, который вы возвращаете из свойства, будет время от времени находиться в состоянии изменения из-за внутреннего обновления. Это означает, что внешний код, вызывающий свойство, должен будет заблокировать сам контейнер перед доступом к его содержимому. Однако вам не нужна блокировка для возврата ссылки на контейнер.
- Состояние гонки, если вы вызываете EndUpdate, а затем BeginUpdate сразу после друг друга, у старого потока еще не было возможности выйти
Я бы сказал, что прежде чем вы начнете беспокоиться о том, что и когда блокировать, вам следует исправить код, чтобы в нем не было множества других проблем, связанных с потоками.
krosenvald верен, блокировка аксессора Objects снимается, как только свойство возвращает указатель на объект-контейнер ...
В вашем коде
List<Objects> objects = foo_instance.Objects;
foreach (Object o in objects)
{
Thread.Sleep(31173);
}
Блокировка длится только для первой строки ... где заполняется ссылочная переменная "objects" ... На самом деле нет необходимости блокировать что-либо для этой строки, так как память не изменяется путем выборки указателя ...
Было бы возможное нарушение доступа, если бы объект 'o' использовался и получал доступ внутри foreach?
Что вы имеете в виду под «нарушением доступа»? Разумеется, не будет конкуренции за блокировку, поскольку цель блокировки освободит locj к моменту начала foreach ...
Спасибо, хорошее понимание. Пришлось дать вам словесную вишенку, так как я не могу голосовать. ;>