我在GetConsumingEnumerable返回的Enumerable上等待Task.WhenAll.

我的问题是：Task.WhenAll的重载是否接收到IEnumerable“准备好”可能会收到无穷无尽的任务？

我只是不确定我是否可以这样做,或者它是否意味着以这种方式使用？

private async Task RunAsync(TimeSpan delay,CancellationToken cancellationToken)
{
    using (BlockingCollection<Task> jobcollection = new BlockingCollection<Task>())
    {
        Task addingTask = Task.Run(async () =>
        {
            while (true)
            {
                DateTime utcNow = DateTime.UtcNow;
                var jobs = Repository.GetAllJobs();
                foreach (var job in GetRootJobsDue(jobs,utcNow))
                {
                    jobcollection.Add(Task.Run(() => RunJob(job,jobs,cancellationToken,utcNow),cancellationToken),cancellationToken);
                }

                await Task.Delay(delay,cancellationToken);
            }
        },cancellationToken);

        await Task.WhenAll(jobcollection.GetConsumingEnumerable(cancellationToken));
    }
}

解决方法

• 上一篇：c# – KeyDown事件没有从网格中提升下一篇：c# – Web Api 2或通用处理程序来提