Rx調用PublishSubject.onNext（）和接收它之間的時間間隔很長

Question

在後臺線程中，我呼叫PublishSubject.onNext();，並在主線程中通過subscribe(PublishSubject.filter(message -> message.getId() == id), this::onMessageInserted);我收到它。平均持續時間大約需要20毫秒。有沒有辦法讓這個時間更少？

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

Answer 1

我不認爲這是可能的。

主要問題是要使用主活套將物品從後臺運送到主線程。

它執行所有系統操作，例如佈局，繪圖，調用生命週期方法，並且在活套完成所有動作之後，它運行添加到其隊列的動作。

當您使用一些調度程序切換到主線程時，每次它獲取一個項目時，它都會將runnable添加到活套隊列中，但正如您所看到的，不會立即調用runnable，而是在Loopers循環的末尾。

時間20ms接近平均繪製時間（主要活套工作的頻率）。