如何在不阻塞 UI 线程的情况下继续执行多个任务？

在我的 MVVM 应用程序中，我的视图模型调用 3 个不同的服务方法，将每个方法的数据转换为通用格式，然后使用属性通知/可观察集合等更新 UI。

服务层的每个方法都会启动一个新的Task并返回Task到视图模型。这是我的一种服务方法的示例。

public class ResourceService
{
internal static Task LoadResources(Action<IEnumerable<Resource>> completedCallback, Action<Exception> errorCallback)
{
    var t = Task.Factory.StartNew(() =>
    {
        //... get resources from somewhere
        return resources;
    });

    t.ContinueWith(task =>
    {
        if (task.IsFaulted)
        {
            errorCallback(task.Exception);
            return;
        }
        completedCallback(task.Result);
    }, TaskScheduler.FromCurrentSynchronizationContext());

    return t;
}
}

这是视图模型的调用代码和其他相关部分......

private ObservableCollection<DataItem> Data = new ObservableCollection<DataItem>();

public ICollectionView DataView
{
    get { return _dataView; }
    set
    {
        if (_dataView != value)
        {
            _dataView = value;
            RaisePropertyChange(() => DataView);
        }
    }
}

private void LoadData()
{
    SetBusy("Loading...");

    Data.Clear();

    Task[] tasks = new Task[3]
    {
        LoadTools(),
        LoadResources(),
        LoadPersonel()
    };

    Task.WaitAll(tasks);

    DataView = CollectionViewSource.GetDefaultView(Data);
    DataView.Filter = FilterTimelineData;

    IsBusy = false;
}

private Task LoadResources()
{
    return ResourceService.LoadResources(resources =>
    {
        foreach(var r in resources)
        {
            var d = convertResource(r);
            Data.Add(d);
        }
    },
    error => 
    {
        // do some error handling
    });
}

这几乎可以工作，但有一些小问题。

第 1 号：在呼叫中SetBusy在一开始，在我开始任何任务之前以及在我打电话之前WaitAll，我设置了IsBusy属性为真。这应该会更新 UI 并显示 BusyIndi​​cator 控件，但它不起作用。我还尝试添加简单的字符串属性并绑定它们，但它们也没有被更新。 IsBusy 功能是基类的一部分，适用于其他视图模型，在这些模型中我没有运行多个任务，因此我不认为 XAML 中的属性通知或数据绑定存在问题。

所有数据绑定似乎在整个方法完成后都已更新。我在输出窗口中没有看到任何“首次异常”或绑定错误，这使我相信 UI 线程在调用 WaitAll 之前以某种方式被阻止。

第二：我似乎从服务方法返回了错误的任务。我想要之后的一切WaitAll在视图模型转换回调中所有服务方法的所有结果后运行。但是，如果我从服务方法返回延续任务，则永远不会调用延续任务，并且WaitAll永远等待。奇怪的是，绑定到 ICollectionView 的 UI 控件实际上正确显示了所有内容，我认为这是因为 Data 是一个可观察的集合，并且 CollectionViewSource 知道集合更改事件。

您可以使用TaskFactory.ContinueWhenAll http://msdn.microsoft.com/en-us/library/system.threading.tasks.taskfactory.continuewhenall%28v=vs.100%29.aspx构建一个在输入任务全部完成时运行的延续。

Task[] tasks = new Task[3]
{
    LoadTools(),
    LoadResources(),
    LoadPersonel()
};

Task.Factory.ContinueWhenAll(tasks, t =>
{
    DataView = CollectionViewSource.GetDefaultView(Data);
    DataView.Filter = FilterTimelineData;

    IsBusy = false;
}, CancellationToken.None, TaskContinuationOptions.None, 
   TaskScheduler.FromCurrentSynchronizationContext());

请注意，如果您使用 C# 5，这会变得更简单await/async syntax:

private async void LoadData()
{
    SetBusy("Loading...");

    Data.Clear();

    Task[] tasks = new Task[3]
    {
        LoadTools(),
        LoadResources(),
        LoadPersonel()
    };

    await Task.WhenAll(tasks);

    DataView = CollectionViewSource.GetDefaultView(Data);
    DataView.Filter = FilterTimelineData;

    IsBusy = false;
}

但是，如果我从服务方法返回延续任务，则永远不会调用延续任务，并且 WaitAll 会永远等待

问题是您的延续任务需要 UI 线程，并且您正在阻塞 UI 线程WaitAll称呼。这会造成一个无法解决的僵局。

修复上述问题应该可以纠正这个问题 - 您需要将延续作为任务返回，因为这就是您需要等待完成的内容 - 但是通过使用TaskFactory.ContinueWhenAll您释放 UI 线程，以便它可以处理这些延续。

请注意，这是 C# 5 简化的另一件事。您可以将其他方法编写为：

internal static async Task LoadResources(Action<IEnumerable<Resource>> completedCallback, Action<Exception> errorCallback)
{
  try
  {
    await Task.Run(() =>
    {
        //... get resources from somewhere
        return resources;
    });
  }
  catch (Exception e)
  {
    errorCallback(task.Exception);
  }

  completedCallback(task.Result);
}

话虽这么说，通常最好编写返回一个的方法Task<T>而不是提供回调，因为这简化了两端的使用。