RxSwift中timer不受runloop的影響可以正常計(jì)時(shí)，以下探索timer實(shí)現(xiàn)原理。
Timer
- swift創(chuàng)建timer
override func viewDidLoad() {
super.viewDidLoad()
// Do any additional setup after loading the view.
timer = Timer.init(timeInterval: 1, target: self, selector: #selector(timerFire), userInfo: nil, repeats: true)
RunLoop.current.add(timer, forMode: .default)
}
@objc func timerFire() {
print(NSDate())
}
/*
輸出結(jié)果：
2019-08-04 10:27:38 +0000
2019-08-04 10:27:39 +0000
2019-08-04 10:27:40 +0000
2019-08-04 10:27:41 +0000
2019-08-04 10:27:42 +0000
……
*/
- 當(dāng)頁(yè)面有滾動(dòng)事件時(shí)定時(shí)器會(huì)停止計(jì)時(shí)，滾動(dòng)事件結(jié)束定時(shí)器繼續(xù)計(jì)時(shí)。
- 把定時(shí)器加到Runloop的
.commonMode中，滾動(dòng)事件不影響定時(shí)器計(jì)時(shí)，但是在commonMode里執(zhí)行會(huì)影響整個(gè)程序，且不容易處理
- Timer.scheduledTimer的寫法
timer = Timer.scheduledTimer(timeInterval: 1, target: self, selector: #selector(timerFire), userInfo: nil, repeats: true)
- Timer.scheduledTimer的寫法在頁(yè)面有滾動(dòng)事件時(shí)定時(shí)器會(huì)停止計(jì)時(shí)，說(shuō)明此方法加進(jìn)了runloop的
.defaultMode里
DispatchSourceTimer
- swift創(chuàng)建gcdTimer
gcdTimer = DispatchSource.makeTimerSource()
gcdTimer?.schedule(deadline: DispatchTime.now(), repeating: DispatchTimeInterval.seconds(1))
gcdTimer?.setEventHandler(handler: {
print("gcdTimer:\(NSDate())")
})
gcdTimer?.resume()
/*
輸出結(jié)果：
gcdTimer:2019-08-04 11:18:13 +0000
gcdTimer:2019-08-04 11:18:14 +0000
gcdTimer:2019-08-04 11:18:15 +0000
gcdTimer:2019-08-04 11:18:16 +0000
gcdTimer:2019-08-04 11:18:17 +0000
……
*/
- gcdTimer，滾動(dòng)事件不影響定時(shí)器計(jì)時(shí)，這種方式計(jì)時(shí)更準(zhǔn)確有效
- gcdTimer操作
gcdTimer?.suspend() //掛起，gcdTimer掛起后一定要取消置空
gcdTimer?.cancel() //取消，先取消再置空
gcdTimer = nil //置空
CADisplayLink
- swift創(chuàng)建cadTimer
cadTimer = CADisplayLink(target: self, selector: #selector(timerFire))
cadTimer?.preferredFramesPerSecond = 1
cadTimer?.add(to: RunLoop.current, forMode: .default)
- cadTimer也是加入到runloop的
.defaultMode里，滾動(dòng)事件時(shí)定時(shí)器會(huì)停止計(jì)時(shí)
RxSwift timer
- RxSwift創(chuàng)建timer
Observable<Int>.interval(1, scheduler: MainScheduler.instance).subscribe(onNext: { (num) in
print(num)
})
.disposed(by: disposeBag)
- RxSwift的timer計(jì)時(shí)不受滑動(dòng)時(shí)間影響，底層是封裝了GCD執(zhí)行計(jì)時(shí)
- interval的實(shí)現(xiàn)
public static func interval(_ period: RxTimeInterval, scheduler: SchedulerType)
-> Observable<Element> {
return Timer(
dueTime: period,
period: period,
scheduler: scheduler
)
}
-
Timer類的實(shí)現(xiàn)
Timer類繼承于Producer，執(zhí)行run方法，run方法里創(chuàng)建TimerSink
/*繼承于Producer，執(zhí)行run方法，Producer里的run方法由子類來(lái)實(shí)現(xiàn)*/
final private class Timer<Element: RxAbstractInteger>: Producer<Element> {
fileprivate let _scheduler: SchedulerType
fileprivate let _dueTime: RxTimeInterval
fileprivate let _period: RxTimeInterval?
// 初始化
init(dueTime: RxTimeInterval, period: RxTimeInterval?, scheduler: SchedulerType) {
self._scheduler = scheduler //調(diào)度環(huán)境
self._dueTime = dueTime //定時(shí)器發(fā)起事件
self._period = period //間隔時(shí)間
}
//執(zhí)行run方法
override func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where Observer.Element == Element {
if self._period != nil {
//創(chuàng)建TimerSink，然后執(zhí)行sink.run
let sink = TimerSink(parent: self, observer: observer, cancel: cancel)
let subscription = sink.run()
return (sink: sink, subscription: subscription)
}
else {
let sink = TimerOneOffSink(parent: self, observer: observer, cancel: cancel)
let subscription = sink.run()
return (sink: sink, subscription: subscription)
}
}
}
- TimerSink，init初始化，實(shí)現(xiàn)run方法
final private class TimerSink<Observer: ObserverType> : Sink<Observer> where Observer.Element : RxAbstractInteger {
typealias Parent = Timer<Observer.Element>
private let _parent: Parent
private let _lock = RecursiveLock()
init(parent: Parent, observer: Observer, cancel: Cancelable) {
self._parent = parent
super.init(observer: observer, cancel: cancel)
}
func run() -> Disposable {
//執(zhí)行schedulePeriodic方法
return self._parent._scheduler.schedulePeriodic(0 as Observer.Element, startAfter: self._parent._dueTime, period: self._parent._period!) { state in
self._lock.lock(); defer { self._lock.unlock() }
self.forwardOn(.next(state))
return state &+ 1
}
}
}
- schedulePeriodic方法，創(chuàng)建了GCD計(jì)時(shí)器并處理定時(shí)器回調(diào)
func schedulePeriodic<StateType>(_ state: StateType, startAfter: RxTimeInterval, period: RxTimeInterval, action: @escaping (StateType) -> StateType) -> Disposable {
let initial = DispatchTime.now() + startAfter
var timerState = state
// 創(chuàng)建GCD計(jì)時(shí)器
let timer = DispatchSource.makeTimerSource(queue: self.queue)
timer.schedule(deadline: initial, repeating: period, leeway: self.leeway)
// TODO:
// This looks horrible, and yes, it is.
// It looks like Apple has made a conceputal change here, and I'm unsure why.
// Need more info on this.
// It looks like just setting timer to fire and not holding a reference to it
// until deadline causes timer cancellation.
var timerReference: DispatchSourceTimer? = timer
let cancelTimer = Disposables.create {
timerReference?.cancel()
timerReference = nil
}
//定時(shí)器回調(diào)，保存的定時(shí)器事件
timer.setEventHandler(handler: {
//容錯(cuò)條件
if cancelTimer.isDisposed {
return
}
//發(fā)送狀態(tài)
timerState = action(timerState)
})
timer.resume()
return cancelTimer
}
- action是閉包的傳值，往上找可以在TimerSink的run方法找到action的實(shí)現(xiàn)，action里執(zhí)行self.forwardOn(.next(state))發(fā)送消息，也就是執(zhí)行subscribe(onNext:)方法返回到閉包里執(zhí)行打印
func run() -> Disposable {
return self._parent._scheduler.schedulePeriodic(0 as Observer.Element, startAfter: self._parent._dueTime, period: self._parent._period!) { state in //尾隨閉包action實(shí)現(xiàn)
self._lock.lock(); defer { self._lock.unlock() }
self.forwardOn(.next(state))
return state &+ 1 //按位與操作，地址+1，改變狀態(tài)
}
}
- timer序列停止計(jì)時(shí)
override func touchesBegan(_ touches: Set<UITouch>, with event: UIEvent?) {
//timer已經(jīng)加入到disposeBag里，這里將disposeBag重新賦值即可銷毀timer停止計(jì)時(shí)
disposeBag = DisposeBag()
}
