Observable.Interval 未以预期频率更新 UI

Question

我正在尝试模拟时钟的行为。为此，我创建了一个Observable.Interval，它在指定的时间间隔后，将属性的值更新相同的时间量。该值是数据绑定到 GUI 的。

问题是：“时钟”的运行速度比预期的慢很多，也就是说，时钟值增加一秒需要超过一秒的时间。

所需的时间分辨率越精细（下面的 MILLIS_INTERVAL 的值），问题就越严重（我用 1、10、100 和 1000 的其他约数对其进行了测试，因为 TimeSpan.FromMilliseconds 被记录为具有最大分辨率为 1 毫秒）。

我希望 observable 回调异步运行，并定期触发，可能并行触发，尽管执行需要时间，但似乎频率越大，滞后越多。

视图模型

使用系统； 使用 System.ComponentModel； 使用 System.Reactive.Linq； 命名空间间隔时钟 { 公共类 ViewModel：INotifyPropertyChanged { 公共双 TimeSeconds { 得到 { 返回 _timeSeconds; } 放 { _timeSeconds = 值； PropertyChanged?.Invoke(this, new PropertyChangedEventArgs("TimeSeconds")); } } 双 _timeSeconds; 常量双 MILLIS_INTERVAL = 10; 公共视图模型（） { Observable.Interval(TimeSpan.FromMilliseconds(MILLIS_INTERVAL)) .Subscribe(token => TimeSeconds += MILLIS_INTERVAL / 1000); } 公共事件 PropertyChangedEventHandler PropertyChanged； } }

主窗口：

<Window x:Class="IntervalClock.MainWindow"
        xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation"
        xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml"
        xmlns:d="http://schemas.microsoft.com/expression/blend/2008"
        xmlns:mc="http://schemas.openxmlformats.org/markup-compatibility/2006"
        xmlns:local="clr-namespace:IntervalClock"
        mc:Ignorable="d">

    <Window.DataContext>
        <local:ViewModel/>
    </Window.DataContext>

    <StackPanel HorizontalAlignment="Center" VerticalAlignment="Center">
        <TextBlock Text="{Binding TimeSeconds, StringFormat=N3}" FontSize="30"/>
    </StackPanel>
</Window>

Answer 1

Observable.Interval 运算符计算运行每个 .OnNext 以触发的间隔。因此，如果.OnNext 需要 0.1 秒并且您的间隔为 1.0 秒，那么您的有效期限为 1.1 秒。但当然，Windows 不是实时操作系统，所以它有漂移。您的实际时间可能会有更大的变化 - 尤其是当您的系统处于负载状态时。

我会这样做：

var interval = TimeSpan.FromSeconds(1.0);
Observable
    .Create<long>(o =>
    {
        var sw = Stopwatch.StartNew();
        return
            Observable
                .Timer(TimeSpan.Zero, TimeSpan.FromSeconds(interval.TotalSeconds / 10.0))
                .Select(x => (long)sw.Elapsed.TotalSeconds)
                .DistinctUntilChanged()
                .Subscribe(o);
    })

使用StopWatch 可为您提供出色的时间准确度。计时器的触发频率大约是 interval 的 10 倍，因此它在触发时会出现 +/- 10% 的错误，但结果是相同的 - 您从这个可观察到的值返回了一个非常准确的“秒”值，只是不是每秒都精确返回。

Answer 2

计时器似乎在同一个线程上调用OnNext，因此回调没有“异步”执行。

您可以创建自己的方法来调用线程池线程上的回调。下面是一个使用System.Timers.Timer 类的基本示例：

public static IObservable<long> Interval(TimeSpan interval)
{
    return Observable.Create<long>(observer =>
    {
        long i = 0;
        Timer _timer = new Timer(interval.TotalMilliseconds);
        _timer.Elapsed += (s, e) => observer.OnNext(i++);
        _timer.Start();

        return Disposable.Create(() =>
        {
            _timer.Stop();
            _timer.Dispose();
        });
    });
}

用法（只需调用您自己的Interval 方法而不是Observable.Interval）：

Interval(TimeSpan.FromMilliseconds(MILLIS_INTERVAL))
                  .Subscribe(token => TimeSeconds += MILLIS_INTERVAL / 1000);

这应该使“回调异步运行，并定期触发，可能是并行的，尽管执行需要时间......”。