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



Download 6,27 Mb.
Pdf ko'rish
bet655/658
Sana12.06.2023
Hajmi6,27 Mb.
#950840
1   ...   650   651   652   653   654   655   656   657   658
Bog'liq
CLR via C Programmirovanie na platforme Microsoft NET Framework 4 5 na yazyke C


Глава.30 .Гибридные.конструкции.синхронизации.потоков
private Int32 m_state = 0; 
private Boolean IsFree { get { return m_state == 0; } } 
private Boolean IsOwnedByWriter { get { return m_state == 1; } } 
private Boolean IsOwnedByReaders { get { return m_state > 0; } } 
private Int32 AddReaders(Int32 count) { return m_state += count; } 
private Int32 SubtractReader() { return m_state; } 
private void MakeWriter() { m_state = 1; } 
private void MakeFree() { m_state = 0; } 
#endregion 
// Для отсутствия конкуренции (с целью улучшения производительности
// и сокращения затрат памяти)
private readonly Task m_noContentionAccessGranter; 
// Каждый ожидающий поток записи пробуждается через свой объект
// TaskCompletionSource, находящийся в очереди
private readonly Queue> m_qWaitingWriters = 
new Queue>(); 
// Все ожидающие потоки чтения пробуждаются по одному
// объекту TaskCompletionSource 
private TaskCompletionSource m_waitingReadersSignal = 
new TaskCompletionSource(); 
private Int32 m_numWaitingReaders = 0; 
public AsyncOneManyLock() { 
m_noContentionAccessGranter = Task.FromResult(null); 

public Task WaitAsync(OneManyMode mode) { 
Task accressGranter = m_noContentionAccessGranter; // Предполагается
// отсутствие конкуренции
Lock(); 
switch (mode) { 
case OneManyMode.Exclusive: 
if (IsFree) { 
MakeWriter(); // Без конкуренции
} else { 
// Конкуренция: ставим в очередь новое задание записи
var tcs = new TaskCompletionSource(); 
m_qWaitingWriters.Enqueue(tcs); 
accressGranter = tcs.Task; 

break;
case OneManyMode.Shared: 
if (IsFree || (IsOwnedByReaders && m_qWaitingWriters.Count == 0)) { 
AddReaders(1); // Отсутствие конкуренции
} else { // Конкуренция
// Увеличиваем количество ожидающих заданий чтения
m_numWaitingReaders++; 


887
Асинхронная.синхронизация
accressGranter = 
m_waitingReadersSignal.Task.ContinueWith(t => t.Result); 

break; 

Unlock(); 
return accressGranter; 

public void Release() { 
TaskCompletionSource accessGranter = null;
Lock(); 
if (IsOwnedByWriter) MakeFree(); // Ушло задание записи
else SubtractReader(); // Ушло задание чтения
if (IsFree) { 
// Если ресурс свободен, пробудить одно ожидающее задание записи
// или все задания чтения
if (m_qWaitingWriters.Count > 0) { 
MakeWriter(); 
accessGranter = m_qWaitingWriters.Dequeue(); 
} else if (m_numWaitingReaders > 0) { 
AddReaders(m_numWaitingReaders); 
m_numWaitingReaders = 0; 
accessGranter = m_waitingReadersSignal; 
// Создание нового объекта TCS для будущих заданий,
// которым придется ожидать
m_waitingReadersSignal = new TaskCompletionSource(); 


Unlock(); 
// Пробуждение задания чтения/записи вне блокировки снижает
// вероятность конкуренции и повышает производительность
if (accessGranter != null) accessGranter.SetResult(null); 

}
Как я уже упоминал, этот код вообще не блокирует выполнение потоков, по-
скольку в его внутренней реализации не используются конструкции ядра. В нем 
используется класс 
SpinLock
, в реализации которого задействованы конструкции 
пользовательского режима. Но если вы вспомните из обсуждения 
SpinLock
в гла-
ве 29, этот класс следует использовать только для секций кода, заведомо выпол-
няемых за короткое и конечное время. Проанализировав мой метод 
WaitAsync
, вы 
увидите, что во время удержания блокировки я ограничиваюсь незначительными 
целочисленными вычислениями и сравнениями и, возможно, созданием объекта 
TaskCompletionSource
и его добавлением в очередь. Все это не займет много вре-


888

Download 6,27 Mb.

Do'stlaringiz bilan baham:
1   ...   650   651   652   653   654   655   656   657   658




Ma'lumotlar bazasi mualliflik huquqi bilan himoyalangan ©hozir.org 2024
ma'muriyatiga murojaat qiling

kiriting | ro'yxatdan o'tish
    Bosh sahifa
юртда тантана
Боғда битган
Бугун юртда
Эшитганлар жилманглар
Эшитмадим деманглар
битган бодомлар
Yangiariq tumani
qitish marakazi
Raqamli texnologiyalar
ilishida muhokamadan
tasdiqqa tavsiya
tavsiya etilgan
iqtisodiyot kafedrasi
steiermarkischen landesregierung
asarlaringizni yuboring
o'zingizning asarlaringizni
Iltimos faqat
faqat o'zingizning
steierm rkischen
landesregierung fachabteilung
rkischen landesregierung
hamshira loyihasi
loyihasi mavsum
faolyatining oqibatlari
asosiy adabiyotlar
fakulteti ahborot
ahborot havfsizligi
havfsizligi kafedrasi
fanidan bo’yicha
fakulteti iqtisodiyot
boshqaruv fakulteti
chiqarishda boshqaruv
ishlab chiqarishda
iqtisodiyot fakultet
multiservis tarmoqlari
fanidan asosiy
Uzbek fanidan
mavzulari potok
asosidagi multiservis
'aliyyil a'ziym
billahil 'aliyyil
illaa billahil
quvvata illaa
falah' deganida
Kompyuter savodxonligi
bo’yicha mustaqil
'alal falah'
Hayya 'alal
'alas soloh
Hayya 'alas
mavsum boyicha


yuklab olish