当一个昂贵的操作发生并且线程冻结超过 RxJava 间隔时间时会发生什么

如何解决当一个昂贵的操作发生并且线程冻结超过 RxJava 间隔时间时会发生什么

我像这样使用 RxJava 间隔：

compositeDisposable.add(
    Observable.interval(1,TimeUnit.SECONDS)
        .flatMap(tick -> {
            return Observable.just(doWork(tick));
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(this::updateUI,e -> {
            disableIndicator();
            FirebaseCrashlytics.getInstance().recordException(e);
        })
);

public Status doWork(long tick) {
    // Doing heavy task
    // Here the Status is an Enum class
    return output
}

public void updateUI(Status value) {
    // Updates UI accordingly
}

一切都按预期进行，但我有一个顾虑。所以我的 doWork() 方法在 bg 中做了一些繁重的任务，我正在根据该方法产生的结果更新 updateUI() 方法中的 UI。我正在调用 doWork() 每秒 使用 RxJava 间隔。通常执行 doWork() 方法所需的时间不到一秒钟。所以我只是想知道如果我有很多数据并且 doWork() 方法执行时间超过一秒会发生什么，假设它需要 2 秒。但是间隔将继续调用 doWork() 方法每隔第二。由于我之前的执行需要另外一秒钟才能完成，我将得到什么作为返回值？

解决方法

所以事情是这样的：

• 假设方法 doWork 执行命令的时间超过一秒，下一次执行会排队但不会延迟。
• 假设在 n 秒内，该方法执行了一些需要 3 秒才能完成的昂贵操作，并会产生结果 A。由于该方法在 1 秒后被执行，将有另外 3 次执行将排队，执行和产生的时间不会超过一秒，并将生成结果 B,C,{{ 1}}。
• D 秒后，您将同时获得所有四个结果。那将是 n+3 A B C

因此，如果您希望在 D 秒和 A n+3 B 秒后看到结果 C（意味着您没有想要一次获得所有四个值），你需要做这样的事情：

D