为什么Rx Timer会二次触发？.NET 4.8 WinForms Shift键检测异常问题

实现背景 #

• 需求：检测WinForms窗体内Shift键的按下/松开状态，解决Shift作为修饰键、焦点落在标签等控件上时无法触发普通按键按下/抬起事件的问题
• 实现思路：每收到一次高频触发的按键数据时重置定时器，通过Rx流超时逻辑判定Shift键松开状态
• 运行环境：.NET 4.8 WinForms应用

原始实现代码：

public partial class Form1 : Form
{
    private readonly Subject<bool> _shiftObservable;

    public Form1()
    {
        InitializeComponent();

        _shiftObservable = new Subject<bool>();
    }

    private void Form1_Load(object sender, EventArgs e)
    {
        lblCurrent.Text = "Load.";

        var statusSignal = _shiftObservable
            .Select(st => st)
            .Publish()
            .RefCount();
        
        // 延迟后输出false，之后保持静默的可观察对象
        var badTimer = Observable
            .Return(false)
            .Delay(TimeSpan.FromMilliseconds(200))
            .Concat(Observable.Never<bool>());

        // 收到状态信号就重置计时器的重复逻辑
        var badSignal = badTimer.TakeUntil(statusSignal).Repeat();

        // 合并信号并监听
        var res = Observable
            .Merge(statusSignal, badSignal)
            .DistinctUntilChanged()
            .Replay(1)
            .RefCount()
            .ObserveOn(this)
            .Subscribe(OnNext, OnError, OnCompleted);
    }

    private void OnNext(bool state) => lblCurrent.Text = state ? "1" : "0"; // 必须在UI线程执行
    private void OnError(Exception ex) => Debug.WriteLine("Exception!");
    private void OnCompleted() => Debug.WriteLine("Completed!");

    protected override bool ProcessCmdKey(ref Message msg, Keys keyData)
    {
        if (keyData == (Keys.Shift | Keys.ShiftKey))
        {
            _shiftObservable.OnNext(true);
            return true; // 若要抑制原始按键处理返回true
        }
        return base.ProcessCmdKey(ref msg, keyData);
    }
}

现存问题 #

Q1 多余false事件抖动 #

按下Shift时预期状态切换流程为0→1，实际运行时状态变为0→1→0→1，存在无来源的false事件。

Q2 大量线程退出日志 #

运行代码时会快速输出大量线程退出日志，日志内容如下：

The thread 0x6d24 has exited with code 0 (0x0).
The thread 0x5180 has exited with code 0 (0x0).
The thread 0x64c8 has exited with code 0 (0x0).
The thread 0x5298 has exited with code 0 (0x0).
The thread 0x3200 has exited with code 0 (0x0).
The thread 0x1c70 has exited with code 0 (0x0).

修复方案 #

Q1 抖动问题修复 #

问题根源：按住Shift时ProcessCmdKey会高频触发true事件，每次事件都会终止当前badTimer并触发Repeat逻辑启动新的计时器，新计时器启动后200ms间隙如果刚好没收到新的按键事件，就会推送false，之后新的按键事件到来又推送true，形成抖动。
修复逻辑：简化Rx流组合，直接用Throttle相关逻辑实现超时判定，按键事件触发时直接推送当前true状态，超时200ms无新事件则推送false，配合DistinctUntilChanged去重。
修改后的核心Rx代码：

private void Form1_Load(object sender, EventArgs e)
{
    lblCurrent.Text = "Load.";

    var shiftState = _shiftObservable
        // 每次收到按键事件先推送true
        .Select(_ => Observable.Return(true)
            // 200ms无新事件则推送false，指定调度器避免线程频繁创建
            .Concat(Observable.Return(false).Delay(TimeSpan.FromMilliseconds(200), SynchronizationContext.Current)))
        // 新事件到来时取消上一个未完成的流
        .Switch()
        .DistinctUntilChanged()
        .ObserveOn(this)
        .Subscribe(OnNext, OnError, OnCompleted);
}

Q2 线程退出日志修复 #

问题根源：默认Delay操作符使用线程池调度器，每次延迟都会分配新的线程池线程，执行完成后线程退出产生日志。
修复逻辑：在Delay等定时操作符中显式指定当前UI同步上下文作为调度器（如上面Q1修复代码中所示），即可复用UI线程的调度队列，不会再产生大量线程退出日志，无需忽略日志。

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