1. 首页
  2. 问题列表
  3. 用For循环[重复]异步和等待
提问者：小点点

用For循环[重复]异步和等待


我有一个Windows服务，它根据日程运行各种作业。在确定要运行哪些作业之后，调度对象列表被发送到一个方法，该方法通过列表进行迭代并运行每个作业。问题是，由于外部数据库调用，一些作业可能需要长达10分钟的时间才能运行。

我的目标是不要有一个作业阻塞其他在队列中，基本上有一个以上的运行一次。我认为使用async和await可以解决这个问题，但我以前从未使用过这些。

当前代码:

public static bool Load(List<Schedule> scheduleList)
{
    foreach (Schedule schedule in scheduleList)
    {
        Load(schedule.ScheduleId);
    }

    return true;
}

public static bool Load(int scheduleId)
{
    // make database and other external resource calls 
    // some jobs run for up to 10 minutes   

    return true;
}

我尝试更新到以下代码:

public async static Task<bool> LoadAsync(List<Schedule> scheduleList)
{
    foreach (Schedule schedule in scheduleList)
    {
        bool result = await LoadAsync((int)schedule.JobId, schedule.ScheduleId);
    }

    return true;
}

public async static Task<bool> LoadAsync(int scheduleId)
{
    // make database and other external resource calls 
    // some jobs run for up to 10 minutes   

    return true;
}

问题是第一个LoadAsync在将控制权交还给循环之前等待作业完成，而不是允许所有作业启动。

我有两个问题:


共3个答案

匿名用户

高级-异步等待是最佳选择，还是应该使用不同的方法？

非常适合您正在尝试做的事情，即同时卸载多个IO绑定的任务。

需要更新哪些内容来允许循环在不阻塞的情况下启动所有作业，但在所有作业完成之前不允许函数返回？

您的循环当前正在等待，因为您每次调用。您需要的是同时执行它们，而不是使用:

public async static Task<bool> LoadAsync(List<Schedule> scheduleList)
{
   var scheduleTaskList = scheduleList.Select(schedule => 
                          LoadAsync((int)schedule.JobId, schedule.ScheduleId)).ToList();
   await Task.WhenAll(scheduleTaskList);

   return true;
}

匿名用户

对于扇出并行异步调用，您希望启动任务以启动它们运行，但随后将它们作为异步未来值或承诺值进行处理。您可以在结束时同步/等待它们。

最简单的方法是将for-loop转换为如下所示:

List<Task<bool>> jobs = new List<Task<bool>>();
foreach (var schedule in scheduleList)
{
    Task<bool> job = LoadAsync((int) schedule.JobId, schedule.ScheduleId); // Start each job
    jobs.Add(job);
}
bool[] finishedJobStatuses = await Task.WhenAll(jobs); // Wait for all jobs to finish running
bool allOk = Array.TrueForAll(finishedJobStatuses, p => p);

匿名用户

我建议使用parallel.foreach。它不是异步的，并行地运行每个迭代。正是你需要的。

public static bool Load(IEnumerable<Schedule> scheduleList)
{
    // set the number of threads you need
    // you can also set CancellationToken in the options
    var options = new ParallelOptions { MaxDegreeOfParallelism = 5 };

    Parallel.ForEach(scheduleList, options, async schedule =>
    {
        await Load(schedule.ScheduleId);
    });

    return true;
}

相关问题