在dispose之后的Reactive Rx 2.0 EventLoopScheduler ObjectDisposedException

我正在使用Rx 2.0的EventLoopScheduler来排队/序列化工作。 当我需要处理调度程序时，如果还有剩余的工作，我将收到一个未处理的ObjectDisposedException。 这是预期的行为吗？

人为/示例代码：

EventLoopScheduler scheduler = new EventLoopScheduler(); List handles = new List(); for (int i = 0; i < 100; ++i) { var handle = Observable.Interval(TimeSpan.FromMilliseconds(1)) .ObserveOn(scheduler) .Subscribe(Observer.Create((x) => Thread.Sleep(1000))); handles.Add(handle); } Thread.Sleep(TimeSpan.FromSeconds(1)); foreach (var handle in handles) handle.Dispose(); scheduler.Dispose(); Console.ReadLine(); 

堆栈跟踪：

  System.ObjectDisposedException at System.Reactive.Concurrency.EventLoopScheduler.Schedule[TState](TState state, TimeSpan dueTime, Func`3 action) at System.Reactive.Concurrency.LocalScheduler.Schedule[TState](TState state, Func`3 action) at System.Reactive.Concurrency.Scheduler.c__DisplayClass50`1.b__4e(TState state2) at System.Reactive.ScheduledObserver`1.Run(Object state, Action`1 recurse) at System.Reactive.Concurrency.Scheduler.c__DisplayClass50`1.b__4d(TState state1) at System.Reactive.Concurrency.Scheduler.InvokeRec1[TState](IScheduler scheduler, Pair`2 pair) at System.Reactive.Concurrency.ScheduledItem`2.InvokeCore() at System.Reactive.Concurrency.ScheduledItem`1.Invoke() at System.Reactive.Concurrency.EventLoopScheduler.Run() at System.Threading.ThreadHelper.ThreadStart_Context(Object state) at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx) at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx) at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state) at System.Threading.ThreadHelper.ThreadStart() 

类似于这个未解答的问题： 在使用EventLoopScheduler之后RX2.0：ObjectDisposedException

Answer 1

是的，我之前也见过 – 我认为没有办法“清除事件线程”本身，但你可以这样做：

 EventLoopScheduler scheduler = new EventLoopScheduler(); var wrappedScheduler = scheduler.Catch((ex) => { Console.WriteLine("Got an exception:" + ex.ToString()); return true; }); for (int i = 0; i < 100; ++i) { var handle = Observable.Interval(TimeSpan.FromMilliseconds(1)) .ObserveOn(wrappedScheduler) .Subscribe(Observer.Create((x) => Thread.Sleep(1000))); handles.Add(handle); } 

Answer 2

这并不是剩下的工作（即调度程序仍然在其队列中有东西），而是你仍然有未完成的订阅试图将东西添加到该队列。

处置所有订阅，然后处置调度程序，它应该正常工作