RxJava2 實戰知識梳理(9) 使用 timer interval delay 實現任務調度

1、前言

其實在以前的文章中，咱們已經接觸過定時/週期執行任務的操做符，例如在 RxJava2 實戰知識梳理(5) - 簡單及進階的輪詢操做 和 RxJava2 實戰知識梳理(6) - 基於錯誤類型的重試請求 這兩篇文章當中，咱們經過intervalRange實現了輪詢工做，經過timer實現了延時的重試請求。

今天這篇文章，咱們根據 RxJava-Android-Samples 中總結的幾種場景來複習一下能夠實現定時調度任務的操做符：

• timer：建立型操做符，用於延時執行任務。
• interval：建立型操做符，用於週期執行任務。
• delay：輔助型操做，用於延時傳遞數據。

2、timer

2.1 timer 操做符原理

timer原理圖以下所示：

很簡單，在訂閱以後，它會在等待一段時間以後發射一個 0數據項，而後結束，所以它經常能夠用來延時地發送時間，例如 RxJava2 實戰知識梳理(5) - 簡單及進階的輪詢操做 中，咱們使用 repeatWhen發起重訂閱時，就是經過 timer實現了延時發送 onNext時間來實現時延變長的輪詢操做。

2.2 使用 timer 延時 1s 後執行任務，而後結束

咱們使用timer操做符實現下面的效果：延時1s後在子線程執行任務，接着完成，這裏咱們採用了timer，並經過subscribe方法讓下游運行在子線程當中。

//延遲 1s 後執行一個任務，而後結束
    private void startTimeDemo1() {
        Log.d(TAG, "startTimeDemo1");
        DisposableObserver<Long> disposableObserver = getTimeDemoObserver();
        Observable.timer(1000, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.io()).subscribe(disposableObserver);
        mCompositeDisposable.add(disposableObserver);
    }
複製代碼

運行結果爲：

3、interval

3.1 interval 原理

interval的原理圖以下所示：

interval也是一個建立型操做符，它能夠間隔一段時間就發送一個數據。

3.2 每隔 1s 執行一次任務，第一次任務執行前有 1s 的間隔，執行無限次

咱們先使用interval實現下面這個效果：每隔1s執行一次任務，第一次任務執行前有1s的間隔，執行無限次。這是由於，使用interval操做符時，默認第一次個任務須要延時和指定間隔相同的時間。

//每隔 1s 執行一次任務，第一次任務執行前有 1s 的間隔，執行無限次
    private void startTimeDemo2() {
        Log.d(TAG, "startTimeDemo2");
        DisposableObserver<Long> disposableObserver = getTimeDemoObserver();
        Observable.interval(1000, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.io()).subscribe(disposableObserver);
        mCompositeDisposable.add(disposableObserver);
    }
複製代碼

運行結果以下所示：

3.3 每隔 1s 執行一次任務，當即執行第一次任務，執行無限次

若是但願當即執行第一次任務，那麼能夠給它提供額外的參數，指定第一次任務的延時：

//每隔 1s 執行一次任務，當即執行第一次任務，執行無限次
    private void startTimeDemo3() {
        Log.d(TAG, "startTimeDemo3");
        DisposableObserver<Long> disposableObserver = getTimeDemoObserver();
        Observable.interval(0, 1000, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.io()).subscribe(disposableObserver);
        mCompositeDisposable.add(disposableObserver);
    }
複製代碼

運行結果爲：

3.4 每隔 1s 執行一次任務，當即執行第一次任務，只執行五次

在3.3的例子中，咱們的任務會無限執行下去，若是咱們但願只執行指定次數該怎麼辦呢，其實在 RxJava2 實戰知識梳理(5) - 簡單及進階的輪詢操做 中演示固定時延的輪詢操做時，咱們已經介紹了使用intervalRange來實現，今天，咱們採用interval + take的方式來實現，代碼以下：

//每隔 1s 執行一次任務，當即執行第一次任務，只執行五次
    private void startTimeDemo4() {
        Log.d(TAG, "startTimeDemo4");
        DisposableObserver<Long> disposableObserver = getTimeDemoObserver();
        Observable.interval(0, 1000, TimeUnit.MILLISECONDS).take(5).subscribe(disposableObserver);
        mCompositeDisposable.add(disposableObserver);
    }
複製代碼

運行結果爲：

take的原理圖以下所示：

它表示咱們只接受前 n個數據項，這樣和 interval結合就能夠實現固定間隔與固定次數的任務執行。

4、delay

4.1 delay 原理

delay的原理圖以下所示：

當它接受一個時間段時，每當原始的 Observable發射了一個數據項時，它就啓動一個定時器，等待指定的時間後再將這個數據發射出去，所以表現爲發射的數據項進行了平移，可是它只會平移 onNext/onComplete，對於 onError，它會當即發射出去，而且丟棄以前等待發射的 onNext事件。

4.2 先執行一個任務，等待 1s，再執行另外一個任務，而後結束

由於delay不是建立型操做符，因此咱們能夠用來延遲上游發射過來的數據，下面，讓咱們實現這個效果：先執行一個任務，等待 1s，再執行另外一個任務，而後結束。代碼以下：

//先執行一個任務，等待 1s，再執行另外一個任務，而後結束
    private void startTimeDemo5() {
        Log.d(TAG, "startTimeDemo5");
        DisposableObserver<Long> disposableObserver = getTimeDemoObserver();
        Observable.just(0L).doOnNext(new Consumer<Long>() {

            @Override
            public void accept(Long aLong) throws Exception {
                Log.d(TAG, "執行第一個任務");
            }

        }).delay(1000, TimeUnit.MILLISECONDS).subscribe(disposableObserver);
        mCompositeDisposable.add(disposableObserver);
    }
複製代碼

執行效果爲：

---

更多文章，歡迎訪問個人 Android 知識梳理系列：

• Android 知識梳理目錄：www.jianshu.com/p/fd82d1899…
• 我的主頁：lizejun.cn
• 我的知識總結目錄：lizejun.cn/categories/