我有一种情况,我正在启动Task-s
,我希望他们的结果以某种方式尽快在数据结构中传输/排队,而不关心他们的顺序。
IAsyncEnumerable
适合这种情况吗?
public async Task BigMethod()
{
Queue<int> queue = new Queue<int>();
foreach (var item in RunJobsAsync())
{
queue.Enqueue(item);
}
//await foreach(var item in await RunIAsyncJobsAsync())
// {
// queue.Enqueue(item);
// }
// [some more code]
}
没有IAsyncEnumerable
public async Task<IEnumerable<int> RunJobsAsync()
{
List<Task<int>> tasks = new List<Task<int>>();
foreach(var x in Enumerable.Range(0,100))
{
tasks.Add(Task.Run(async()=> await someMethodAsync()));
}
await tasks.WhenAll(tasks);
return tasks.Select(x=>x.Result);
}
和IAsyncEnumerable
public async IAsyncEnumerable<int> RunIAsyncJobsAsync()
{
foreach (var x in Enumerable.Range(0, 100))
{
yield return await Task.Run(async () => await someMethodAsync());
}
}
是否有任何性能提升,IAsyncEnumerable
因为我最终希望在所有调用完成之前不进一步使用算法async
,但我希望它们并行执行,因此而不是按顺序等待所有它们,我想只需等待最长的完成即可。
PS在这种情况下,我需要ConcurrentQueue
/locking 吗?