WPF ViewModel中如何轮询异步方法更新ObservableCollections

嘿，看你一直在跟进Stephen Cleary的内容，他在异步编程这块的分享真的太实用了！针对你说的Windows平台下，要轮询API获取JSON数据、更新ObservableCollection还不能阻塞UI的需求，我给你整理几个经过实践验证的靠谱方案：

这个方案逻辑直观，用异步循环实现轮询，全程通过await释放UI线程，完全不会卡顿：

private async Task PollApiAndUpdateCollectionsAsync(CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        try
        {
            // 异步请求API，这里不会阻塞UI线程
            var rawJson = await FetchApiJsonAsync();
            // 解析JSON并转换成对应的数据模型
            var parsedData = ParseJsonToDataModels(rawJson);

            // 必须在UI线程更新ObservableCollection，用Dispatcher调度
            Application.Current.Dispatcher.Invoke(() =>
            {
                // 这里可以根据需求选择全量替换或者增量更新
                UpdateFullCollection(FirstObservableCollection, parsedData.FirstListItems);
                UpdateFullCollection(SecondObservableCollection, parsedData.SecondListItems);
            });
        }
        catch (Exception ex)
        {
            // 异常处理，比如打日志或者给用户提示
            Debug.WriteLine($"轮询出错：{ex.Message}");
        }

        // 延迟指定时间再发起下一次请求，同样不阻塞UI
        await Task.Delay(TimeSpan.FromSeconds(30), cancellationToken);
    }
}

// 封装全量更新集合的逻辑，减少重复代码
private void UpdateFullCollection<T>(ObservableCollection<T> collection, IEnumerable<T> newItems)
{
    collection.Clear();
    foreach (var item in newItems)
    {
        collection.Add(item);
    }
}

核心点：await会让UI线程在等待API响应和延迟期间继续处理用户交互，Dispatcher.Invoke确保集合更新操作在UI线程执行，符合Windows平台的线程规则。

如果你的项目用的是较新的.NET版本，IAsyncEnumerable能把轮询逻辑和更新逻辑拆分开，代码更简洁易维护：

// 定义轮询数据流，返回解析后的数据
private async IAsyncEnumerable<ApiParsedData> PollApiStreamAsync([EnumeratorCancellation] CancellationToken cancellationToken)
{
    while (!cancellationToken.IsCancellationRequested)
    {
        var rawJson = await FetchApiJsonAsync();
        yield return ParseJsonToDataModels(rawJson);
        await Task.Delay(TimeSpan.FromSeconds(30), cancellationToken);
    }
}

// 启动轮询并更新集合
private async Task StartPollingWorkflowAsync(CancellationToken cancellationToken)
{
    await foreach (var parsedData in PollApiStreamAsync(cancellationToken))
    {
        Application.Current.Dispatcher.Invoke(() =>
        {
            UpdateFullCollection(FirstObservableCollection, parsedData.FirstListItems);
            UpdateFullCollection(SecondObservableCollection, parsedData.SecondListItems);
        });
    }
}

这种方式把轮询的“数据流”单独封装，后续如果要修改轮询逻辑或者扩展数据处理，会非常方便。

如果API返回的数据包含增量变化，或者你可以对比新旧数据，建议用增量更新代替全量替换，减少UI刷新的开销：

// 假设你的数据模型有唯一标识Id，且实现了INotifyPropertyChanged
private void UpdateCollectionIncrementally<T>(ObservableCollection<T> collection, IEnumerable<T> newItems) where T : class, IHasId
{
    var existingIds = collection.Select(item => item.Id).ToHashSet();
    var newItemsById = newItems.ToDictionary(item => item.Id);

    // 删除已不存在的项
    var itemsToRemove = collection.Where(item => !newItemsById.ContainsKey(item.Id)).ToList();
    foreach (var item in itemsToRemove)
    {
        collection.Remove(item);
    }

    // 更新现有项，添加新项
    foreach (var newItem in newItems)
    {
        if (existingIds.Contains(newItem.Id))
        {
            var existingItem = collection.First(item => item.Id == newItem.Id);
            // 更新现有项的属性（因为实现了INotifyPropertyChanged，UI会自动刷新）
            existingItem.UpdateFrom(newItem);
        }
        else
        {
            collection.Add(newItem);
        }
    }
}

这里需要你的数据模型实现INotifyPropertyChanged接口，这样更新属性时UI会自动同步，不用重新添加整个项，性能和用户体验都会更好。

一定要记得在不需要轮询的时候（比如页面关闭、用户停止操作）取消任务，避免内存泄漏：

private CancellationTokenSource _pollingCts;

// 启动轮询
private void StartPolling()
{
    _pollingCts = new CancellationTokenSource();
    // 用_ = 避免编译器警告，因为我们不需要等待这个任务完成（除非有特殊需求）
    _ = PollApiAndUpdateCollectionsAsync(_pollingCts.Token);
}

// 停止轮询，比如在页面Unloaded事件中调用
private void StopPolling()
{
    _pollingCts?.Cancel();
    _pollingCts?.Dispose();
}

如果你的项目用了MVVM框架（比如Prism、MvvmLight），可以用框架提供的调度器（比如DispatcherHelper）代替Application.Current.Dispatcher，更符合MVVM的设计规范。

内容的提问来源于stack exchange，提问作者Dev