Асинхронность в цикле C#?

Question

[Alex Wells]

Здравствуйте. Есть foreach цикл, который собирает данные и вызывает функцию с этими данными. Но эта ф-я выполняется довольно долго, хотелось-бы запустить функции сразу для всех данных из цикла. Собственно про асинхронность читал, но не очень вьехал, к тому-же не знаю как оно будет работать с циклом и вообще что может случится. Работать должно примерно так:

1) Поток while(true), с задержкой после выполнения 1 секунда
2) Берутся данные с одного АПИ.
3) Обрабатываются, получается цикл.
4) В цикле вызывается асинхронная ф-я для каждой ячейки данных.
5) Не дожидаясь обработки ф-ий подождать 1 секунду и снова послать запрос на АПИ.
6) Все с начала, при этом не допуская вызов ф-й с данными, которые еще не обработались с предыдущего запроса

Весь код уже есть, осталась только асинхронность. Кто знает как сделать это правильно? Ф-я ничего не возвращает.

Answer 1

[Роман]

Task.Run

Comments

[Alex Wells]

Ничего мне не говорит. Кучу статей прочитал, но нифига не понятно)

[Роман]

Alex_Wells: metanit.com/sharp/tutorial/12.2.php

плохо искали или читали, в вашем случае (не надо синхронизаций, результатов), хватит Task.Run(делегат, лямбда или метод)

[Alex Wells]

Роман: Попробую. Просто у меня нету возможности протестировать это на локалке, а на продакшине боюсь)

Answer 2

[Виталий Пухов]

самый простой способ использовать parallel for each, но есть минусы, к примеру во время обработки изменять коллекцию нежелательно.
способ получше это построение очереди, то есть выдергивать объекты из списка и кидать в другой список, и уже на другой список вешать обработчики, по 1 на каждый элемент списка. По мере исполнения каждого обработчика переписывать элемент на 1 из общей кучи.
Первый способ простой, нужно заменить пару строк, второй способ лучше, но сложней. По нему делают все нормальные серверы обработки.

Comments

[Alex Wells]

Обработка не большая, всего 2-5 элементов, но при этом на каждый элемент нужно совершить два запроса на стороннее API, которое часто очень сильно лагает (точнее Steam API). По-этому и хочу сделать асинхронность. Что сюда подойдет лучше? Task.Run или parallel for each? С вашим вторым способом не вижу смысла заморачиваться =)

[Виталий Пухов]

Alex_Wells: вопрос не совсем верный)
Parallel for each это обертка- синтаксический сахар над task.run, в вашем случае этого будет достаточно с головой. второй способ был бы смысле если бы было 10000 запросов в очереди и несколько минут на отработку каждого