反应式扩展、锁和线程

Question

我正在使用反应式扩展来处理 wpf ui，基本上我有一个文本框，我需要在小时间跨度（200-300 毫秒）上进行采样和节流（在打字时连续做一些事情，在停止打字时做一些事情

）问题是它有些不可预测，有时会立即触发限制，这可能是因为 TextUpdated 事件没有到达可观察对象或可观察对象本身。我还做了一些可能会干扰的锁定，但这通常是通过新任务完成的，而不是在 UI 线程上完成的。我还偷偷怀疑调试可能会影响行为，因为当我设置断点时，它似乎会触发更多“错误”

由于可观察对象是在 UI 线程上创建的，我假设（可能是错误的）它的计时器或它在下面使用的任何内容也都在对于该线程，创建一个新线程来创建可观察值是否是一个好主意，这样它就不会受到 UI 开销和潜在锁定的干扰？我如何以最好的方式设置这样一个线程，我想在它末尾的空 while 循环可能不是一个好主意:)

Throttle、Sample 工作和与线程相关的反应式扩展如何在以下情况下工作无论如何？

编辑

似乎问题出在我测试它的方式上：P 如果你按住一个键，那么在开始重复之前似乎会有 500 毫秒的延迟，如果你只是敲击按键，它就可以正常工作。叹

Answer 1

Sample 和 Throttle 都使用 Scheduler.ThreadPool 进行计时，所以我非常怀疑这就是问题所在。

我建议在代码中添加一些日志记录以找出瓶颈所在：

sourceEvents.LogInterval("Source")
    .Throttle(throttleTimeSpan).LogInterval("Throttled")
    .Sample(sampleTimeSpan).LogInterval("Sample")
    .Subscribe();

这是 LogInterval 的定义：

public static class ObservableEx
{
    public static IObservable<TSource> LogInterval(
        this IObservable<TSource> source, string message)
    {
        return source
            .TimeInterval()
            .Do(x => Debug.WriteLine("{0} :: {1} ({2})", 
                message, x.Value, x.Interval.TotalMilliseconds);
            .RemoveTimeInteval();
    }
}

如果瓶颈是节流/样本，则可能意味着您在其他地方使 ThreadPool 饱和。如果是这种情况，并且这些限制的性能很重要，您可以考虑创建一个专用的线程+调度程序，并为 Throttle/Sample 使用自定义 DistpatcherScheduler。或者，可能有更好的 TPL 方法来解决它。