Необходимо понять использование SemaphoreSlim. ⇐ C#
-
Anonymous
Необходимо понять использование SemaphoreSlim.
Вот код, который у меня есть, но я не понимаю, что делает SemaphoreSlim.
async Task WorkerMainAsync() { SemaphoreSlim ss = новый SemaphoreSlim(10); List trackedTasks = новый List(); в то время как (DoMore()) { ожидайте ss.WaitAsync(); trackedTasks.Add(Task.Run(() => { DoPollingThenWorkAsync(); сс.Выпуск(); })); } ждут Task.WhenAll(trackedTasks); } void DoPollingThenWorkAsync() { вар сообщение = Опрос(); если (сообщение != ноль) { Поток.Сон(2000); // обрабатываем длительное задание, связанное с процессором } } Что делают await ss.WaitAsync(); и ss.Release();?
Я предполагаю, что если я запущу 50 потоков одновременно, а затем напишу код типа SemaphoreSlim ss = new SemaphoreSlim(10);, то он будет вынужден запускать 10 активных потоков одновременно.
>
Когда один из 10 потоков завершится, запустится другой поток. Если я не прав, помогите мне разобраться на примере ситуации.
Почему await необходим вместе с ss.WaitAsync();? Что делает ss.WaitAsync();?
Вот код, который у меня есть, но я не понимаю, что делает SemaphoreSlim.
async Task WorkerMainAsync() { SemaphoreSlim ss = новый SemaphoreSlim(10); List trackedTasks = новый List(); в то время как (DoMore()) { ожидайте ss.WaitAsync(); trackedTasks.Add(Task.Run(() => { DoPollingThenWorkAsync(); сс.Выпуск(); })); } ждут Task.WhenAll(trackedTasks); } void DoPollingThenWorkAsync() { вар сообщение = Опрос(); если (сообщение != ноль) { Поток.Сон(2000); // обрабатываем длительное задание, связанное с процессором } } Что делают await ss.WaitAsync(); и ss.Release();?
Я предполагаю, что если я запущу 50 потоков одновременно, а затем напишу код типа SemaphoreSlim ss = new SemaphoreSlim(10);, то он будет вынужден запускать 10 активных потоков одновременно.
>
Когда один из 10 потоков завершится, запустится другой поток. Если я не прав, помогите мне разобраться на примере ситуации.
Почему await необходим вместе с ss.WaitAsync();? Что делает ss.WaitAsync();?
