RxSwift 中的排程器
與 ReactiveCocoa 相比,Rx 的一大優勢就是更豐富的併發模型。提到併發,就不得不提多執行緒。在 RxSwift 中,與執行緒對應的概念就是排程器,本文就排程器做些介紹,包括併發排程器、序列排程器、RxSwift 內建的排程器,及自定義排程器。
文章地址:ofollow,noindex" target="_blank">https://www.cnblogs.com/xjshi/p/9759551.html
排程器抽象出了執行工作的機制,可以不怎麼準確的認為排程器對應原本的執行緒。
observeOn
、subscribeOn
這兩個操作符可以與排程器配合使用。
如果你想在一個不同的排程器執行工作,那就使用observeOn(scheduler)
操作符。
如果沒有顯式指定observerOn
,那麼工作會在產生元素的排程器來執行。
下邊是一個使用observeOn
的例子:
sequence1 .observeOn(backgroundScheduler) .map { n in print("This is performed on the background scheduler") } .observeOn(MainScheduler.instance) .map { n in print("This is performed on the main scheduler") }
如果想要序列在指定排程器上生成(subscribe
方法)和 dispose,可以使用subscribeOn(scheduler)
。
如果沒有明確指定subscribeOn
,那麼將在呼叫subscribe(onNext:)
或subscribe
的同一排程器上呼叫subscribe
閉包(傳遞給Observable.create
的閉包)。
如果沒有明確指定subscribeOn
,那麼將在啟動 disposing 的同一排程器上呼叫dispose
方法。
簡而言之,如果沒有顯式的選擇排程器,那麼將在當前排程器上呼叫這些方法。
序列排程器 vs 併發排程器
由於排程器可以是任何東西,並且所有轉換序列的操作副都需要有額外的保證,因此你建立的是哪種排程器非常重要。
這裡的保證是指,對所有的序列(Observable)而言,不論它在那個執行緒上產生元素,如果序列通過observer.ron(.next(nextElement))
將一個元素髮送給觀察者,那麼序列在observer.on
方法執行結束前不能傳送下一個元素。
如果.next
方法沒有執行完成,序列也不能傳送終止命令,如.completed
或.error
。
這部分內容在RxSwift 入門一文中介紹過。
如果排程器是併發的,Rx 的observeOn
和subscribeOn
操作符將確保一切正常。
如果你使用Rx可以證明是序列的排程器,它能夠執行額外的優化。
在序列排程器的情況下,observeOn
被優化為一個簡單的dispatch_async
呼叫。
自定義排程器
除了當前的排程器,你也可以實現自己的排程器。
如果你想要描述立即執行工作的排程器,可以實現ImmediateScheduler
協議。
public protocol ImmediateScheduler { func schedule<StateType>(state: StateType, action: (/*ImmediateScheduler,*/ StateType) -> RxResult<Disposable>) -> RxResult<Disposable> }
如果你想要支援基於事件的操作,那麼你可以實現Scheduler
協議:
public protocol Scheduler: ImmediateScheduler { associatedtype TimeInterval associatedtype Time var now : Time { get } func scheduleRelative<StateType>(state: StateType, dueTime: TimeInterval, action: (StateType) -> RxResult<Disposable>) -> RxResult<Disposable> }
如果你想有周期執行的能力,你可以通過實現PeriodicScheduler
協議來通知 Rx。
public protocol PeriodicScheduler : Scheduler { func schedulePeriodic<StateType>(state: StateType, startAfter: TimeInterval, period: TimeInterval, action: (StateType) -> StateType) -> RxResult<Disposable> }
內建的排程器
上邊我們提到 Rx 可以使用所有型別的排程器,但如果 Rx 可以證明排程器是序列的,那麼會執行額外的優化
- CurrentThreadScheduler:它是一個序列排程器,表示當前執行工作的排程器。
- MainScheduler:抽象了需要在主執行緒執行的工作,當然也是一個序列排程器。
-
SerialDispatchQueueScheduler:是一個序列排程器,抽象需要在一個
dispatch_queue_t
上執行的工作,它將確保即時傳遞併發排程佇列(concurrent dispatch queue),它也會轉換為序列佇列。主排程器 也是 SerialDispatchQueueScheduler 的一個示例。 -
ConcurrentDispatchQueueScheduler:是一個併發排程器,抽象需要在一個
dispatch_queue_t
上執行的工作。當一些任務需要在後臺執行時,使用這個排程器。 -
OperationQueueScheduler:抽象需要在
NSOperationQueue
上執行的工作。適用於需要在後臺執行大量工作,並希望通過使用maxConcurrentOpeartionCount
來調整併發處理的情況。
本文中的部分表示 與 Rx 中的對照:
本文中的表示 | Rx中的表示 |
---|---|
排程器 | scheduler |
序列排程器 | serial scheduler |
併發排程器 | concurrent scheduler |