后台线程调度操作时，Rx TestScheduler引发NullReference异常

根据一些评论，我应该清楚地表明，这个问题是关于TestScheduler为什么抛出空引用异常，而不是如何使测试通过。一个较早的示例假定与TPL的交互是问题的原因，但我现在发现触发此行为不是必需的，因此我用一个更简单的测试用例替换了代码

我在尝试将rx测试“虚拟时间” TestScheduler与后台线程结合在一起时遇到一些问题。在文章的底部显示了我发现的最简单的方法来演示该问题。

该代码只是在运行一个后台线程，该线程订阅带有超时的可观察序列。

超时是由TestScheduler驱动的，当我在主线程上进行超时时，将生成空引用异常：

断言失败。虚拟时间00：00：00.1394720，异常System.NullReferenceException：对象引用未设置为对象的实例。在System.Reactive.Concurrency.VirtualTimeScheduler 2.GetNext() at System.Reactive.Concurrency.VirtualTimeSchedulerBase2.AdvanceTo（TAbsolute time）处..... UnitTest1.cs：line

该故障似乎对所使用的IObservable的确切类型不敏感，但似乎取决于Timeout选择器的存在。但是有趣的是，测试通常会在虚拟时间失败，因为超时是在火灾引发的超时之前。

运行与控制台应用程序相同的代码也似乎可以正常工作，尽管该问题似乎很容易受到干扰（可能是竞争条件），因此这可能会引起麻烦。

进一步的研究和评论强烈暗示，该行为是由于在后台线程调度其超时操作而使调度程序前进时发生的竞争条件引起的

在此先感谢您提供的任何信息...

using Microsoft.Reactive.Testing;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using System;
using System.Reactive.Linq;
using System.Threading;

namespace UnitTestProject1
{
[TestClass]
public class UnitTest1
{
    [TestMethod]
    public void TestBackgroundThreadWithTestScheduler()
    {
        var scheduler = new TestScheduler();
        var seq = Observable.Never<string>();

        bool subscribed = false;
        ThreadPool.QueueUserWorkItem(_ =>
        {
            Thread.Sleep(100); //wait a bit to give main thread chance to start advancing scheduler
            seq.Timeout(TimeSpan.FromSeconds(10), scheduler)
               .Subscribe(s => {/*never called*/});
            subscribed = true; //signal we're subscribed
        });

        //----  Uncommenting this line to avoid the race condition appears to fix the test ----
        //while (!subscribed) Thread.Yield(); 

        //Advance the scheduer in small increments to maximise our chances of hitting the race
        var watch = scheduler.StartStopwatch();
        try
        {
            while (watch.Elapsed < TimeSpan.FromSeconds(20)) scheduler.AdvanceBy(10);
        }
        //NullReference is thrown unexpectedly
        catch (NullReferenceException ex)
        {
            Assert.Fail("Virtual time {0}, exception {1}", watch.Elapsed, ex);
        }
        catch (TimeoutException)
        {
            //desired result is a TimeoutException so this is a test pass
        }
    }
}
}