android - 调用 PublishSubject.onNext() 和接收它之间的 Rx Interval 很长

Question

在后台线程中，我调用 PublishSubject.onNext(); 并在主线程中通过 subscribe(PublishSubject.filter(message -> message.getId() == id)，这: :onMessageInserted); 我收到了。平均持续时间约为 20 毫秒。有没有办法缩短这个时间？

我们使用
'io.reactivex:rxjava:1.2.5'
'io.reactivex:rxandroid:1.2.1'


Answer 1

我不认为这是可能的。

主要问题是要从后台向主线程传递项目，需要使用主循环程序。

它执行所有系统操作，例如布局、绘制、调用生命周期方法，并且在循环器完成所有这些操作后，它运行添加到其队列中的操作。

当你使用一些调度器切换到主线程时，每次它获得一个项目时它都会将runnable添加到looper队列中，但是你可以看到runnable不会立即被调用，而是在Loopers循环结束时被调用。

20ms的时间接近平均绘制时间(主looper工作的频率)。