场景:遍历一个List集合,每次循环结束都等待一定时间再继续下一次循环。
普通做法
for (String s : strings) {
Thread.sleep(1000);
}
上面这种做法简单粗暴,就是不够优雅,在子线程进行时,循环没结束且刚好在sleep中时,我们尝试interrupt此子线程的时候会抛java.lang.InterruptedException
异常
RxJava做法:使用ZIP操作符
List<String> list = new ArrayList<>();
list.add("1");
list.add("2");
list.add("3");
list.add("4");
list.add("5");
//fromIterable接收一个Iterable,每次发射一个元素(与for循环效果相同)
Observable<String> listObservable = Observable.fromIterable(list);
//interval定时器,间隔1秒发射一次
Observable<Long> timerObservable = Observable.interval(1000, TimeUnit.MILLISECONDS);
//使用zip操作符合并两个Observable
Observable.zip(listObservable, timerObservable, new BiFunction<String, Long, String>() {
@Override
public String apply(String s, Long aLong) throws Exception {
return s;
}
}).doOnNext(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
//此处接收
}
}).subscribe();
zip操作符:
zip操作符
也就是说,通过zip操作符将listObservable
和timerObservable
合并之后,实现的效果就是:
发射list第一个元素 → 延时1秒 → 发射list第二个元素 → 延时1秒......
使用RxJava这种方式实现,要比for循环里使用Thread.sleep()
更加优雅一些,还能避免java.lang.InterruptedException
异常
PS:delay操作符无法实现,因为delay用于事件流中,只能延迟发射事件流中的某一次事件