ReaderWriterLockSlim.EnterUpgradeableReadLock Метод

Определение

Пространство имен:

System.Threading

Сборка:

System.Threading.dll

Исходный код:

ReaderWriterLockSlim.cs

Пытается выполнить вход в блокировку в обновляемом режиме.

public:
 void EnterUpgradeableReadLock();

public void EnterUpgradeableReadLock ();

member this.EnterUpgradeableReadLock : unit -> unit

Public Sub EnterUpgradeableReadLock ()

Исключения

LockRecursionException

Свойство RecursionPolicy имеет значение NoRecursion, а текущий поток уже вошел в блокировку в любом из режимов.

-или-

Текущий поток вошел в режим чтения, поэтому попытка войти в обновляемый режим создаст возможность взаимоблокировки.

-или-

Глубина рекурсии превышает емкость счетчика. Ограничение допускает настолько большое число рекурсивных вхождений, что оно не должно достигаться приложениями на практике.

ObjectDisposedException

Объект ReaderWriterLockSlim был удален.

Примеры

В следующем примере показано, как использовать EnterUpgradeableReadLock метод для ввода блокировки в обновляемом режиме. Блок finally используется для выполнения ExitUpgradeableReadLock метода , гарантируя, что вызывающий объект выходит из обновляемого режима.

Метод, показанный в примере, извлекает значение, связанное с ключом, и сравнивает его с новым значением. Если значение не изменилось, метод возвращает состояние, указывающее на отсутствие изменений. Если значение для ключа не найдено, вставляется пара "ключ-значение". Если значение изменилось, оно обновляется. Обновляемый режим позволяет потоку обновлять блокировку чтения при необходимости без риска взаимоблокировок.

В примере используется конструктор без параметров для создания блокировки, поэтому рекурсия не допускается. Программирование ReaderWriterLockSlim проще и менее подвержено ошибкам, если блокировка не допускает рекурсию.

Этот код является частью более крупного примера, предоставленного ReaderWriterLockSlim для класса .

private ReaderWriterLockSlim cacheLock = new ReaderWriterLockSlim();
private Dictionary<int, string> innerCache = new Dictionary<int, string>();

Private cacheLock As New ReaderWriterLockSlim()
Private innerCache As New Dictionary(Of Integer, String)

public AddOrUpdateStatus AddOrUpdate(int key, string value)
{
    cacheLock.EnterUpgradeableReadLock();
    try
    {
        string result = null;
        if (innerCache.TryGetValue(key, out result))
        {
            if (result == value)
            {
                return AddOrUpdateStatus.Unchanged;
            }
            else
            {
                cacheLock.EnterWriteLock();
                try
                {
                    innerCache[key] = value;
                }
                finally
                {
                    cacheLock.ExitWriteLock();
                }
                return AddOrUpdateStatus.Updated;
            }
        }
        else
        {
            cacheLock.EnterWriteLock();
            try
            {
                innerCache.Add(key, value);
            }
            finally
            {
                cacheLock.ExitWriteLock();
            }
            return AddOrUpdateStatus.Added;
        }
    }
    finally
    {
        cacheLock.ExitUpgradeableReadLock();
    }
}

Public Function AddOrUpdate(ByVal key As Integer, _
                            ByVal value As String) As AddOrUpdateStatus
    cacheLock.EnterUpgradeableReadLock()
    Try
        Dim result As String = Nothing
        If innerCache.TryGetValue(key, result) Then
            If result = value Then
                Return AddOrUpdateStatus.Unchanged
            Else
                cacheLock.EnterWriteLock()
                Try
                    innerCache.Item(key) = value
                Finally
                    cacheLock.ExitWriteLock()
                End Try
                Return AddOrUpdateStatus.Updated
            End If
        Else
            cacheLock.EnterWriteLock()
            Try
                innerCache.Add(key, value)
            Finally
                cacheLock.ExitWriteLock()
            End Try
            Return AddOrUpdateStatus.Added
        End If
    Finally
        cacheLock.ExitUpgradeableReadLock()
    End Try
End Function

public enum AddOrUpdateStatus
{
    Added,
    Updated,
    Unchanged
};

Public Enum AddOrUpdateStatus
    Added
    Updated
    Unchanged
End Enum

Комментарии

Этот метод блокируется до тех пор, пока вызывающий поток не войдет в блокировку и, следовательно, может никогда не вернуться. TryEnterUpgradeableReadLock Используйте метод для блокировки в течение указанного интервала, а затем возвращает значение , если вызывающий поток не перешел в обновляемый режим в течение этого интервала.

Используйте обновляемый режим, когда поток обычно обращается к ресурсу, защищенному ReaderWriterLockSlim , в режиме чтения, но при соблюдении определенных условий может потребоваться перейти в режим записи. Поток в обновляемом режиме может перейти на режим чтения или перейти на режим записи.

Только один поток может перейти в обновляемый режим в любой момент времени. Если поток находится в обновляемом режиме и нет потоков, ожидающих перехода в режим записи, любое количество других потоков может перейти в режим чтения, даже если есть потоки, ожидающие перехода в обновляемый режим.

Если один или несколько потоков ожидают выхода в режим записи, поток, вызывающий EnterUpgradeableReadLock метод, блокирует время ожидания этих потоков или переход в режим записи, а затем выход из него.

Примечание

Если блокировка допускает рекурсию, поток, который вступил в блокировку в обновляемом режиме, может рекурсивно перейти в обновляемый режим, даже если другие потоки ожидают перехода в режим записи.