如何在C#/WPF中实现Win2D Invalidate()式的连续事件合并？

我之前在WPF项目里也碰到过一模一样的需求——就是要复刻Win2D那种能合并连续Invalidate()请求的机制：连续操作只触发一次最终更新，所有变更都不会被忽略。下面给你几个实用的方案，既有现成工具可用，也有轻量的手动实现思路：

方案一：利用WPF自身Dispatcher消息循环（零依赖，最轻量化） #

WPF的UI线程消息队列是按优先级处理的，渲染相关操作在DispatcherPriority.Render级别执行。我们可以利用这一点实现自动合并的更新机制：

public class InvalidateManager
{
    private bool _isUpdatePending;
    private readonly Dispatcher _uiDispatcher;
    private readonly List<Action> _pendingUpdates = new List<Action>();

    public InvalidateManager(Dispatcher uiDispatcher)
    {
        _uiDispatcher = uiDispatcher;
    }

    // 对外暴露的Invalidate方法，传入本次要执行的变更操作
    public void Invalidate(Action updateAction)
    {
        // 线程安全地收集所有待执行的变更
        lock (_pendingUpdates)
        {
            _pendingUpdates.Add(updateAction);
        }

        // 只有当没有待处理的更新时，才触发一次批量处理
        if (!_isUpdatePending)
        {
            _isUpdatePending = true;
            // 在Render优先级下执行批量更新，WPF会自动合并同优先级的消息
            _uiDispatcher.InvokeAsync(ProcessAllUpdates, DispatcherPriority.Render);
        }
    }

    private void ProcessAllUpdates()
    {
        List<Action> updatesToExecute;
        // 锁定并取出所有待执行的变更
        lock (_pendingUpdates)
        {
            updatesToExecute = new List<Action>(_pendingUpdates);
            _pendingUpdates.Clear();
            _isUpdatePending = false;
        }

        // 执行所有攒下来的变更
        foreach (var update in updatesToExecute)
        {
            update();
        }

        // 触发最终的重绘逻辑
        TriggerRedraw();
    }

    private void TriggerRedraw()
    {
        // 替换成你的实际重绘代码，比如：
        // MyChartControl.InvalidateVisual();
    }
}

使用时，每次点击添加线条就这么调用：

// 初始化时创建manager实例
private readonly InvalidateManager _invalidateManager = new InvalidateManager(Application.Current.Dispatcher);

// 点击事件里调用
_invalidateManager.Invalidate(() =>
{
    // 添加新线条到数据集合
    ChartData.Lines.Add(new LineModel(/* 线条参数 */));
});

这个方案的核心是：多次调用Invalidate会把所有变更操作攒起来，等WPF准备渲染时一次性执行，自动合并连续的请求，完全符合你要的效果。

方案二：用Rx正确实现批量收集（解决你之前的使用误区） #

你之前说Rx的合并/节流会忽略先前调用，其实是用错了操作符。应该用Buffer+Throttle组合，收集一段时间内的所有请求，而不是只保留最后一个：

public class RxInvalidateManager : IDisposable
{
    private readonly Subject<Action> _updateSubject = new Subject<Action>();
    private readonly IDisposable _updateSubscription;

    public RxInvalidateManager()
    {
        // 收集100ms内的所有更新请求，当超过100ms无新请求时一次性处理
        _updateSubscription = _updateSubject
            .Buffer(_updateSubject.Throttle(TimeSpan.FromMilliseconds(100)))
            .Subscribe(ExecuteBatchUpdates);
    }

    public void Invalidate(Action updateAction)
    {
        _updateSubject.OnNext(updateAction);
    }

    private void ExecuteBatchUpdates(IList<Action> updates)
    {
        foreach (var update in updates)
        {
            update();
        }
        TriggerRedraw();
    }

    private void TriggerRedraw()
    {
        // 你的重绘逻辑
    }

    // 记得在控件销毁时释放资源
    public void Dispose()
    {
        _updateSubscription.Dispose();
        _updateSubject.Dispose();
    }
}

这里的Buffer会把所有在Throttle等待期内的请求都收集起来，等没有新请求时一次性执行。你可以调整Throttle的时间，比如设为TimeSpan.Zero，效果就和Dispatcher方案一致。

方案三：用现成MVVM库的Debounce工具类 #

如果你已经在用MVVM库，比如Microsoft.Toolkit.Mvvm（微软官方的MVVM工具包），它自带的DebounceDispatcher可以直接帮你实现延迟合并：

private readonly DebounceDispatcher _debounceDispatcher = new DebounceDispatcher();
private readonly List<Action> _pendingUpdates = new List<Action>();

public void Invalidate(Action updateAction)
{
    lock (_pendingUpdates)
    {
        _pendingUpdates.Add(updateAction);
    }

    // 延迟100ms执行，连续调用会重置延迟时间，最后只执行一次
    _debounceDispatcher.Debounce(100, () =>
    {
        List<Action> updatesToExecute;
        lock (_pendingUpdates)
        {
            updatesToExecute = new List<Action>(_pendingUpdates);
            _pendingUpdates.Clear();
        }

        foreach (var update in updatesToExecute)
        {
            update();
        }
        TriggerRedraw();
    });
}

这个方案最省心，不需要自己处理线程和消息队列，直接用现成工具类即可。

总结 #

• 不想加任何依赖？优先用方案一，完全利用WPF自身机制，性能最优；
• 已经在用Rx？调整操作符用方案二，灵活性更高；
• 在用MVVM库？直接用方案三的现成工具。

这三个方案都能实现你要的效果：连续点击100次会一次性添加所有线条，窗口resize时也只会重绘一次。

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