-
timer：創(chuàng)建型操作符，用于延時(shí)執(zhí)行任務(wù) -
interval：創(chuàng)建型操作符，用于周期執(zhí)行任務(wù) -
delay：輔助型操作，用于延時(shí)傳遞數(shù)據(jù)
1.timer
timer原理圖如下所示：
timer.png
timer()只是用來(lái)創(chuàng)建一個(gè)Observable，并延遲發(fā)送一次的操作符，timer()并不會(huì)按周期執(zhí)行
//延遲 1s 后執(zhí)行一個(gè)任務(wù)，然后結(jié)束
private void startTimeDemo1() {
DisposableObserver<Long> disposableObserver = getObserver();
Observable.timer(1000, TimeUnit.MILLISECONDS)
.subscribeOn(Schedulers.io())
.subscribe(disposableObserver);
mCompositeDisposable.add(disposableObserver);
}
2.interval
interval原理圖如下所示：
interval.png
interval()也是用來(lái)創(chuàng)建Observable的，并且也可以延遲發(fā)送，但interval()是按周期執(zhí)行的
//每隔 1s 執(zhí)行一次任務(wù)，第一次任務(wù)執(zhí)行前有 1s 的間隔，執(zhí)行無(wú)限次
private void startTimeDemo2() {
DisposableObserver<Long> disposableObserver = getObserver();
Observable.interval(1000, TimeUnit.MILLISECONDS)
.subscribeOn(Schedulers.io())
.subscribe(disposableObserver);
mCompositeDisposable.add(disposableObserver);
}
3. delay
delay原理圖如下所示：
delay.png
delay()：延遲一段指定的時(shí)間再發(fā)送來(lái)自Observable的發(fā)送結(jié)果，其實(shí)
delay()的常規(guī)使用跟timer()一致。delay()是用于流中的操作，跟map()、flatMap()的級(jí)別是一樣的，而timer()是用于創(chuàng)建Observable
//先執(zhí)行一個(gè)任務(wù)，等待 1s，再執(zhí)行另一個(gè)任務(wù)，然后結(jié)束
private void startTimeDemo5() {
DisposableObserver<Long> disposableObserver = getObserver();
Observable.just(0L).doOnNext(new Consumer<Long>() {
@Override
public void accept(Long aLong) throws Exception {
Log.d(TAG, "執(zhí)行第一個(gè)任務(wù)");
}
})
.delay(1000, TimeUnit.MILLISECONDS)
.subscribe(disposableObserver);
mCompositeDisposable.add(disposableObserver);
}
