首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >ObserveOnDispatcher不调用UI线程中的处理程序

ObserveOnDispatcher不调用UI线程中的处理程序
EN

Stack Overflow用户
提问于 2015-09-14 13:07:41
回答 1查看 489关注 0票数 3

我有一个消息总线类,它使用Rx在WPF应用程序中推送多个线程事件。我的问题ObserveOnDispatcher没有在UI线程中调用事件处理程序。

代码:

代码语言:javascript
复制
private void button_Click(object sender, RoutedEventArgs e)
{
  var messageBus = new MessageBus();
  messageBus.GetMessages<Message>().ObserveOnDispatcher().Subscribe(x => TestHanlder(x));

  Trace.WriteLine("Main Thread Id:" + Thread.CurrentThread.ManagedThreadId);
  var deviceManager = new DeviceManager(messageBus);
  deviceManager.Start();
}

private void TestHanlder(Message message)
{
  Trace.WriteLine("UI Handler ThreadId:" + Thread.CurrentThread.ManagedThreadId);
}

public class DeviceManager
{
  private readonly MessageBus _messageBus;

  public DeviceManager(MessageBus messageBus)
  {
    _messageBus = messageBus;
  }

  public void Start()
  {
    for (;;)
    {
      var t = Task.Factory.StartNew(() => BackGroundTask(), TaskCreationOptions.LongRunning);
      t.Wait();
    }
  }

  private void BackGroundTask()
  {
    Thread.Sleep(1000);
    Trace.WriteLine("Push ThreadId:" + Thread.CurrentThread.ManagedThreadId);
    var message = new Message();
    _messageBus.Publish(message);
  }
}

public class MessageBus
{
  readonly ISubject<object> _messages;

  public MessageBus()
  {
    _messages = new Subject<object>();
  }
  public void Publish<TMessage>(TMessage message)
  {
    _messages.OnNext(message);
  }

  public IObservable<TMessage> GetMessages<TMessage>()
  {
    return _messages.OfType<TMessage>();
  }
}

public class Message
{
  public Message()
  {

  }
}
代码语言:javascript
复制
Without ObserveOnDispatcher:
messageBus.GetMessages<Message>().Subscribe(x => TestHanlder(x));
..........................Output.................................
Main Thread Id:8
Push ThreadId:9
UI Handler ThreadId:9
But I need to execute the TestHanlder function in the main thread or UI thread, in my use case above it must be the thread number 8.

When I use ObserveOnDispatcher:
messageBus.GetMessages<Message>().ObserveOnDispatcher().Subscribe(x => TestHanlder(x));
..........................Output.................................

Main Thread Id:9
Push ThreadId:10
 ------------------> UI Handler ThreadId: are missing not there!?
What I'm doing wrong here?!!!!!
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2015-09-14 14:19:25

for (;;) { t.Wait(); }这段代码是在UI线程中执行的,并阻止它执行在其上分派的任何其他代码。ObserveOnDispatcher运行良好,但调度程序线程被阻塞。

如果您引入了异步/等待(这将释放线程),那么这个场景将运行得很好:

代码语言:javascript
复制
    private async void button_Click(object sender, RoutedEventArgs e)
    {
        var messageBus = new MessageBus();
        messageBus.GetMessages<Message>().ObserveOnDispatcher().Subscribe(x => TestHanlder(x));

        Trace.WriteLine("Main Thread Id:" + Thread.CurrentThread.ManagedThreadId);
        var deviceManager = new DeviceManager(messageBus);
        await deviceManager.Start();
    }

    ...

        public async Task<Unit> Start()
        {
            for (;;)
            {
                await Task.Factory.StartNew(() => BackGroundTask(), TaskCreationOptions.LongRunning);
            }
        }
票数 3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/32565665

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档