.net Наблюдаемый 'ObserveOn' фоновый поток

Question

Я пытаюсь реализовать простой шаблон Observer, используя .net Observable класс. У меня есть код, который выглядит следующим образом:

Observable.FromEventPattern<PropertyChangedEventArgs>(
    Instance.User, 
    "PropertyChanged") 
      .Where(e => e.EventArgs.PropertyName == "FirstName") 
      .ObserveOn(Scheduler.ThreadPool) 
      .Subscribe(search => OnFirstNameChanged(search.EventArgs)); 

Observable.FromEventPattern<PropertyChangedEventArgs>(
    Instance.User, 
    "PropertyChanged") 
      .Where(e => e.EventArgs.PropertyName == "LastName") 
      .ObserveOn(Scheduler.ThreadPool) 
      .Subscribe(search => OnLastNameChanged(search.EventArgs)); 

Я хочу наблюдателей работать на фоне потока, но я хочу их всех работать на одной и той же фоновый поток (для нашей реальной реализации, это будет слишком сложно иметь каждого слушателя в другом потоке).

т.е. я хочу все OnXXXChanged логики должны выполняться в потоке, отличном от потока пользовательского интерфейса, но вместо Observing по всей ThreadPool, я хочу, чтобы убедиться, что они работают в правильном порядке, в том же потоке.

Как следует изменить вышеуказанное?

Кроме того, в некоторой смежной заметке есть ли примеры хорошего примера кода с использованием класса Observable для реализации этого шаблона?

Answer 1

Вы должны создать EventLoopScheduler и использовать этот единственный экземпляр во всех вызовах ObserverOn:

var scheduler = new EventLoopScheduler(ts => new Thread(ts)); 

... .ObserveOn(scheduler). ... 

нить, созданная фабричным методом является нить используется для планирования выполнения на. Если оставить свойство ExitIfEmpty, установленное на false, этот поток не будет завершен, даже если нечего делать, чтобы он был повторно использован для каждого вызова.

Однако, вы также можете рассмотреть возможность использования Scheduler.NewThread. Использование этого планировщика позволит потоку завершить работу, если больше нечего делать. Когда больше работы помещено в очередь на ObserverOn, будет создан новый поток, но только один поток должен существовать, означая, что у вас нет синхронизации разных наблюдателей.

Потоки, созданные EventLoopScheduler (используется Scheduler.NewThread), имеют название Event Loop #. Вы увидите эти имена в отладчике.

Answer 2

.ObserveOn(Scheduler.ThreadPool) принимает планировщик потоков, который диктует поток, над которым работает наблюдение. Похоже, что для одного потока вы хотите использовать EventLoopScheduler, а не ThreadPool.