CodeMirror/ShareX
1
0
Fork 0
mirror of https://github.com/ShareX/ShareX.git synced 2024-09-30 01:07:21 +13:00
Code Issues Projects Releases Packages Wiki Activity

Added ForEachAsync

Browse source
This commit is contained in:
Jaex 2021-11-24 07:37:17 +03:00
parent 1332a96ad0
commit 0d7200f30f
1 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
ShareX.HelpersLib/Helpers/Helpers.cs
View file

@ -1665,5 +1665,26 @@ public static string CreateChecksumFile(string filePath)
return null;
}
public static Task ForEachAsync<T>(IEnumerable<T> inputEnumerable, Func<T, Task> asyncProcessor, int maxDegreeOfParallelism)
{
SemaphoreSlim throttler = new SemaphoreSlim(maxDegreeOfParallelism, maxDegreeOfParallelism);
IEnumerable<Task> tasks = inputEnumerable.Select(async input =>
{
await throttler.WaitAsync();
try
{
await asyncProcessor(input);
}
finally
{
throttler.Release();
}
});
return Task.WhenAll(tasks);
}
}
}