|
Глава.30 .Гибридные.конструкции.синхронизации.потоков
более медленный код, к тому же допускающий доступ потоков к поврежденному
состоянию
1
. Поэтому я крайне не рекомендую вам пользоваться инструкцией
lock
.
Теперь перейдем к переменной
lockTaken
типа
Boolean
и к проблеме, которую
призвана решить эта переменная. Предположим, поток вошел в блок
try
и был пре-
рван до вызова метода
Monitor.Enter
(прерывание потоков обсуждалось в главе 22).
После этого вызывается блок
finally
, но его код не должен снимать блокировку.
В этом нам поможет переменная
lockTaken
. Ей присваивается начальное значение
false
, означающее, что блокировка еще не установлена. Если вызванный метод
Monitor.Enter
успешно получает блокировку, переменной
lockTaken
присваивается
значение
true
. Блок
finally
по значению этой переменной определяет, нужно ли
вызывать метод
Monitor.Exit
. Кстати, структура
SpinLock
также поддерживает
паттерн с переменной
lockTaken
.
Класс ReaderWriterLockSlim
Часто потоки просто читают некие данные. Если такие данные защищены взаи-
моисключающей блокировкой (например,
SimpleSpinLock
,
SimpleWaitLock
,
SimpleHybridLock
,
AnotherHybridLock
,
Mutex
или
Monitor
), то при попытке одно-
временного доступа нескольких потоков работу продолжит только один из них,
а остальные блокируются, что значительно ухудшает масштабируемость и снижает
производительность вашего приложения. Впрочем, в случае доступа в режиме
только для чтения необходимость в блокировке отпадает, и потоки получают
одновременный доступ к данным. А вот потоку, который хочет внести в данные
изменения, требуется монопольный доступ. Конструкция
ReaderWriterLockSlim
содержит логику, позволяющую решить данную проблему. Управление потоками
осуществляется следующим образом:
Если один поток осуществляет запись данных, все остальные потоки, требующие
доступа, блокируются.
Если один поток читает данные, все остальные потоки, требующие доступа, про-
должают работу, блокируются только потоки, ожидающие доступа на запись.
После завершения работы потока, осуществлявшего запись данных, разблокиру-
ется либо один поток, ожидающий доступ на запись, либо все потоки, ожидаю-
щие доступ на чтение. При отсутствии заблокированных потоков блокировку
получает следующий поток чтения или записи, которому это потребуется.
После завершения всех потоков, осуществлявших чтение данных, разблокируется
поток, ожидающий разрешения на запись. При отсутствии заблокированных
потоков блокировку получит следующий поток чтения или записи, которому
это потребуется.
1
Кстати говоря, блокировку можно безопасно снять в блоке finally, если код блока try
только читает состояние, не пытаясь его изменять (впрочем, это также приводит к снижению
производительности).
867
Гибридные.конструкции.в.FCL
Вот как выглядит данный класс (некоторые перегруженные версии методов не
показаны):
public class ReaderWriterLockSlim : IDisposable {
public ReaderWriterLockSlim(LockRecursionPolicy recursionPolicy);
public void Dispose();
public void EnterReadLock();
public Boolean TryEnterReadLock(Int32 millisecondsTimeout);
public void ExitReadLock();
public void EnterWriteLock();
public Boolean TryEnterWriteLock(Int32 millisecondsTimeout);
public void ExitWriteLock();
// Большинство приложений никогда не обращаются к этим свойствам
public Boolean IsReadLockHeld { get; }
public Boolean IsWriteLockHeld { get; }
public Int32 CurrentReadCount { get; }
public Int32 RecursiveReadCount { get; }
public Int32 RecursiveWriteCount { get; }
public Int32 WaitingReadCount { get; }
public Int32 WaitingWriteCount { get; }
public LockRecursionPolicy RecursionPolicy { get; }
// Не показаны члены, связанные с переходом от чтения к записи
}
Следующий код демонстрирует применение данной конструкции:
internal sealed class Transaction : IDisposable {
private readonly ReaderWriterLockSlim m_lock =
new ReaderWriterLockSlim(LockRecursionPolicy.NoRecursion);
private DateTime m_timeOfLastTrans;
public void PerformTransaction() {
m_lock.EnterWriteLock();
// Этот код имеет монопольный доступ к данным...
m_timeOfLastTrans = DateTime.Now;
m_lock.ExitWriteLock();
}
public DateTime LastTransaction {
get {
m_lock.EnterReadLock();
// Этот код имеет совместный доступ к данным...
DateTime temp = m_timeOfLastTrans;
m_lock.ExitReadLock();
return temp;
}
}
public void Dispose() { m_lock.Dispose(); }
}
868
Do'stlaringiz bilan baham: |
