Net framework 5, а также среды Visual Studio 2012 и C#

850
Глава.29 .Примитивные.конструкции.синхронизации.потоков
семафоры
Семафоры
(semaphores) также представляют собой обычные переменные типа 
Int32
, 
управляемые ядром. Ожидающий семафора поток блокируется при значении 0 
и освобождается при значениях больше 0. При снятии блокировки с ожидающего 
семафора потока ядро автоматически вычитает единицу из счетчика. С семафорами 
связано максимальное значение типа 
Int32
, которое ни при каких обстоятель-
ствах не могут превысить текущие показания счетчика. Вот как выглядит класс 
Semaphore
:
public sealed class Semaphore : WaitHandle {
public Semaphore(Int32 initialCount, Int32 maximumCount);
public Int32 Release(); // Вызывает Release(1); 
// возвращает предыдущее значение счетчика
public Int32 Release(Int32 releaseCount); // Возвращает предыдущее
// значение счетчика
}
Подытожим, каким образом ведут себя эти три примитива режима ядра:
‰
При наличии нескольких потоков в режиме ожидания событие с автосбросом 
освобождает 
только один
из них.
‰
Событие с ручным сбросом снимает блокировку со 
всех
ожидающих его по-
токов.
‰
При наличии нескольких потоков, ожидающих семафора, его появление снимает 
блокировку с потоков 
releaseCount
(здесь 
releaseCount
— это аргумент, пере-
данный методу 
Release
класса 
Semaphore
).
То есть получается, что событие с автосбросом эквивалентно семафору, мак-
симальное значение счетчика которого равно единице. Разница между ними 
состоит в том, что метод 
Set
для события с автосбросом можно вызвать много 
раз, но каждый раз освобождаться будет всего один поток, в то время как много-
кратный вызов метода 
Release
каждый раз увеличивает на единицу внутренний 
счетчик семафора, давая возможность снять блокировку с большего количества 
потоков. Однако следует помнить, что при вызове метода 
Release
для семафора, 
показание счетчика которого уже равно максимальному, генерируется исключение 
SemaphoreFullException
.
При помощи семафоров можно повторно реализовать класс 
SimpleWaitLock
таким образом, что нескольким потокам будет предоставляться одновременный 
доступ к ресурсу (что безопасно только при условии, что все потоки используют 
ресурс в режиме только для чтения):
public sealed class SimpleWaitLock : IDisposable {
private Semaphore m_AvailableResources;
public SimpleWaitLock(Int32 maximumConcurrentThreads) {
m_AvailableResources =

---

851
Конструкции.режима.ядра
new Semaphore(maximumConcurrentThreads, maximumConcurrentThreads);
}
public void Enter() {
// Ожидаем в ядре доступа к ресурсу и возвращаем управление
m_AvailableResources.WaitOne();
}
public void Leave() {
// Этому потоку доступ больше не нужен; его может получить другой поток
m_ AvailableResources.Release();
}
public void Dispose() { m_AvailableResources.Close(); }
}