RxJava如何创建一个间隔，该间隔具有以不同延迟执行的多个作业？

问题描述

我对RxJava非常陌生，所以我的问题可能完全是愚蠢的，但是我不知道该怎么做。

所以我有N个作业实现了以下接口

interface Worker {
  int interval();
  void job();
}

我想要实现的是一种类似计时器的功能，每次经过Worker时，就会调用这些job() s interval()函数。

到目前为止我尝试过的

Observable.fromArray(worker1,worker2)
                .flatMap(worker -> Observable.just(worker).delay(worker.delay(),TimeUnit.SECONDS))
                .subscribe(Worker::job);

这很好，工作在给定时间过去之后异步执行。

但这仅执行一次。我了解我需要以某种方式使用interval()运算符，但无法将其包围。

预先感谢

解决方法

如果我正确理解了您的问题，则需要执行以下操作：

RazorClassLibrary1

您应注意，在此实现中，您的Observable.fromArray(worker1,worker2) .flatMap { worker -> Observable.interval(worker.interval(),TimeUnit.SECONDS) .flatMap { Observable.just(worker).delay(worker.delay(),TimeUnit.SECONDS) } } .subscribe(Worker::job) 呼叫将以意外的顺序进行