RxSwift学习之旅-Scheduler

先给ObservableType添加两个扩展方法，以便更好的观察线程之间的切换


let start = Date()

fileprivate func getThreadName() -> String {
  if Thread.current.isMainThread {
    return "Main Thread"
  } else if let name = Thread.current.name {
    if name == "" {
      return "Anonymous Thread"
    }
    return name
  } else {
    return "Unknown Thread"
  }
}

fileprivate func secondsElapsed() -> String {
  return String(format: "%02i", Int(Date().timeIntervalSince(start).rounded()))
}

extension ObservableType {
  func dump() -> RxSwift.Observable<Self.E> {
    return self.do(onNext: { element in
      let threadName = getThreadName()
      print("\(secondsElapsed())s | [D] \(element) received on \(threadName)")
    })
  }
  
  func dumpingSubscription() -> Disposable {
    return self.subscribe(onNext: { element in
      let threadName = getThreadName()
      print("\(secondsElapsed())s | [S] \(element) received on \(threadName)")
    })
  }
}

接着创建一个水果类的可观察序列，并调用我们自己写的扩展方法进行subscribe

let globalScheduler = ConcurrentDispatchQueueScheduler(queue: DispatchQueue.global())
let bag = DisposeBag()

let fruit = Observable<String>.create { (observable) -> Disposable in
    observable.onNext("apple")
    sleep(2)
    observable.onNext("banana")
    sleep(2)
    observable.onNext("orange")
    return Disposables.create()
}

fruit
    .dump()
    .dumpingSubscription()
    .addDisposableTo(bag)

看输出

00s | [D] apple received on Main Thread
00s | [S] apple received on Main Thread
02s | [D] banana received on Main Thread
02s | [S] banana received on Main Thread
04s | [D] orange received on Main Thread
04s | [S] orange received on Main Thread

因为我们没有Schedule相关操作。程序默认是在Main Thread上跑的

如我想让序列的发出在后台线程执行应该怎么做呢？

RxSwift给我们提供的非常便捷的两个方法

public func subscribeOn(_ scheduler: ImmediateSchedulerType) -> RxSwift.Observable<Self.E>

封装源序列，以便在指定的调度程序中运行它的订阅和非订阅逻辑这个操作符不常用，这只会在指定的调度器上执行订阅和取消订阅的自定义操作，为了在调度器上调用观察者回调，官方推荐使用observeOn

也就是第二个方法
func observeOn(_ scheduler: [ImmediateSchedulerType]) -> [Observable]<String>

封装源序列，以便在指定的调度程序上运行它的观察者回调。这只调用调度程序的观察者回调。如果订阅和/或取消订阅的操作产生了需要在调度器上运行的自定义操作，官方推荐使用subscribeOn。

如果我们想让这个序列在后台线程进行相关操作应该怎么做呢？

let fruit = Observable<String>.create { (observable) -> Disposable in
    observable.onNext("apple")
    sleep(2)
    observable.onNext("banana")
    sleep(2)
    observable.onNext("orange")
    return Disposables.create()
}.subscribeOn(globalScheduler)

要看到子线程的运行过程，加上下面这行代码
RunLoop.main.run(until: Date(timeIntervalSinceNow: 13))
再看输出

00s | [D] apple received on Anonymous Thread
00s | [S] apple received on Anonymous Thread
02s | [D] banana received on Anonymous Thread
02s | [S] banana received on Anonymous Thread
04s | [D] orange received on Anonymous Thread
04s | [S] orange received on Anonymous Thread

由于我们把调度器切换到后台线程后，并没有在做把线程切换回主线程的操作。那么，可观测序列在哪个线程产生的，也就在哪个线程被订阅。

在实际开发中，我们往往要把一些耗时操作放到后台线程去做，当我们订阅的时候，在主线程拿到结果再去做跟UI相关的一系列操作。所以，正确的姿势应该是这样的

let fruit = Observable<String>.create { (observable) -> Disposable in
    observable.onNext("apple")
    sleep(2)
    observable.onNext("banana")
    sleep(2)
    observable.onNext("orange")
    return Disposables.create()
}.subscribeOn(globalScheduler) // 切换到子线程

fruit
    .dump()
    .observeOn(MainScheduler.instance) // 回到主线程
    .dumpingSubscription()
    .addDisposableTo(bag)

再看输出

00s | [D] apple received on Anonymous Thread
00s | [S] apple received on Main Thread
02s | [D] banana received on Anonymous Thread
02s | [S] banana received on Main Thread
04s | [D] orange received on Anonymous Thread
04s | [S] orange received on Main Thread

RxSwift已经封装好的几种调度器

MainScheduler

主调度器位于主线程的顶部。该调度器用于处理用户界面上的更改，并执行其他高优先级的任务。作为在iOS、tvOS或macOS上开发应用程序的一般实践，不应该使用这个调度器执行长时间运行的任务，因此应该避免服务器请求或其他繁重任务之类的任务。

如果您执行了更新UI的自定义操作，那么您必须切换到主调度器以保证这些更新能使其进入屏幕。

当你打算使用Driver将数据直接绑定到UI时，也应该切换到主调度器

SerialDispatchQueueScheduler

SerialDispatchQueueScheduler管理串行队列DispatchQueue工作。您可以使用这个调度器来处理以串行方式调度的后台作业。

ConcurrentDispatchQueueScheduler

ConcurrentDispatchQueueScheduler,类似于SerialDispatchQueueScheduler管理分发工作。这次的主要区别是，调度程序使用一个并发的队列，而不是一个串行队列
对于需要同时结束的多个长时间运行的任务，并发调度器可能是一个不错的选择。

OperationQueueScheduler

OperationQueueScheduler、ConcurrentDispatchQueueScheduler相似,但是分发的工作在NSOperationQueue执行工作。有时您需要对正在运行的并发作业进行更多的控制，使用DispatchQueue是无法完成的。OperationQueueScheduler您可以定义maxConcurrentOperationCount限制并发操作的数量,以满足应用程序的需求

TestScheduler

专门服务于测试的一个调度器，平时开发的时候不使用。只用于测试

RxSwift学习之旅-Scheduler