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

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