在Android中使用RxJava排队任务

概述我正在开发具有后台数据同步功能的 Android应用程序. 我正在使用RxJava定期在服务器上发布一些数据. 除此之外,我想向用户提供一个按钮“强制同步”,这将立即触发同步. 我知道如何使用Observable.interval()来定期推送数据,我会知道如何使用Observalbe.just()来推送那个被强制的数据,但是如果发生这种情况,我想排队一个在前一个仍然运行时被触发. 所以让我们举个 我正在开发具有后台数据同步功能的 Android应用程序.
我正在使用RxJava定期在服务器上发布一些数据.
除此之外,我想向用户提供一个按钮“强制同步”,这将立即触发同步.
我知道如何使用Observable.interval()来定期推送数据,我会知道如何使用Observalbe.just()来推送那个被强制的数据,但是如果发生这种情况,我想排队一个在前一个仍然运行时被触发.

所以让我们举个例子,当1分钟是自动同步的时间间隔,让我们说同步持续40秒(我过分夸张,只是为了更容易点).现在如果有任何机会,当自动仍然运行时,用户按下“强制”按钮(反之亦然 – 强制人员仍在运行时自动触发),我想排队第二个同步请求,就像第一个完成.

我画了这个图片,这可能会给你一些更多的看法：

如你所见,自动触发(由一些Observable.interval()),并且在同步的中间,用户按“强制”按钮.现在我们要等待第一个请求完成,然后重新开始强制请求.
有一点,当强制请求正在运行时,新的自动请求被再次触发,只是将其添加到队列中.在最后一个从队列中完成后,一切都停止,然后自动再次安排在稍后.

希望有人可以指出我正确的运算符如何做到这一点.我已经尝试过Observable.combineLatest(),但是队列列表是在开始时分派的,当我添加新的同步到队列时,在上一个 *** 作完成时它不会继续.

任何帮助是极大的赞赏,
达科

解决方法 您可以通过将定时器与按钮点击Observable / Subject合并来实现,使用onBackpressureBuffer的排队效果,并将其中的处理结合到一起,以确保每次运行一个.

PublishSubject<Long> subject = PublishSubject.create();Observable<Long> periodic = Observable.interval(1,1,TimeUnit.SECONDS);periodic.mergeWith(subject).onBackpressureBuffer().concatMap(new Func1<Long,Observable<Integer>>() {    @OverrIDe    public Observable<Integer> call(Long v) {        // simulates the task to run        return Observable.just(1)                .delay(300,TimeUnit.MILliSECONDS);    }}).subscribe(System.out::println,Throwable::printstacktrace);Thread.sleep(1100);// user clicks a buttonsubject.onNext(-1L);Thread.sleep(800);

总结

以上是内存溢出为你收集整理的在Android中使用RxJava排队任务全部内容，希望文章能够帮你解决在Android中使用RxJava排队任务所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。