可以说我有3台服务器(具有相同的API):| S1 | S2 | S3 |
| postSomething(data) | postSomething(data) | postSomething(data) |
我需要的是(按顺序):S1-postSomething(100) , S2-postSomething(100) , S3-postSomething(100)
睡觉
做简单的计算S1-postSomething(90) , S2-postSomething(90) , S3-postSomething(90)
睡觉
从域做简单的计算S1-postSomething(80) , S2-postSomething(80) , S3-postSomething(80)
睡觉
做简单的计算
完成所有3次计算后更新域
几点注意事项:
步骤1,4,7不必按顺序进行。但必须在入睡之前完成所有3个请求(我为整个工作使用了单线程线程池,因此这3个帖子是按顺序进行的)。
我不在乎postSomething(data)
响应数据
伪代码:
int value = 100;
List<Observable> tuning = new List()
for (int tuningStep = 0; tuningStep < 10; tuningStep++) {
for (LampUnit lampUnit : lampUnits.getAllLampUnits()) {
// Don't care about response as long gettings success
Observable<Integer> post = service.postSomething(lampUnit.getId(), value);
result.add(post)
}
result.add(() -> {
Thread.sleep(5000L)
return 1;
});
result.add(() -> {
return doCalculations();
});
value -= 10;
}
result.subscribeOn(Schedulers.from(Executors.newFixedThreadPool(1))
.observeOn(Schedulers.from(this.executor))
.subscribe();
最佳答案
可能比您的更伪,但是它可能暗示您想要的解决方案:
int val = 100;
Observable res = Observable.empty();
while(val >= 0) {
res = Observable.concat(
res,
service.postSomething([...], val),
Observable.timer(5, TimeUnit.SECONDS)
);
val -= 10;
}
res.subscribe(); //completion handler will be invoked when done
关于java - RxJava-在循环中合并请求序列,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52074112/