假設我有 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();
1 回答
POPMUISE
TA貢獻1765條經驗 獲得超5個贊
可能比你的更偽，但它可能暗示你想要的解決方案：
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
添加回答
舉報
0/150
提交
取消