使用RxJava实现定时器功能可以通过两种方式来实现，具体实现如下：

一、使用 timer 操作符

private Disposable mDisposable; /** * 启动定时器 */ public void startTime() { Observable.timer(10, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<Long>() { @Override public void onSubscribe(Disposable d) { mDisposable = d; } @Override public void onNext(Long value) { //Log.d("Timer",""+value); } @Override public void onError(Throwable e) { } @Override public void onComplete() { // TODO:2017/12/1 closeTimer(); } }); } /** * 关闭定时器 */ public void closeTimer(){ if (mDisposable != null) { mDisposable.dispose(); } }

二、使用使用 interval 和 take 操作符

在1.x 中 timer 可以执行间隔逻辑，在2.x中此功能已过时，交给了 interval 操作符,当然只使用 interval 还不能实现定时器功能，必须再结合take 操作符。具体代码如下：

private Disposable mDisposable; /** * 启动定时器 */ public void startTime() { int count_time = 10; //总时间 Observable.interval(0, 1, TimeUnit.SECONDS) .take(count_time+1)//设置总共发送的次数 .map(new Function<Long, Long>() { @Override public Long apply(Long aLong) throws Exception { //aLong从0开始 return count_time-aLong; } }) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<Long>() { @Override public void onSubscribe(Disposable d) { mDisposable = d; } @Override public void onNext(Long value) { //Log.d("Timer",""+value); } @Override public void onError(Throwable e) { } @Override public void onComplete() { // TODO:2017/12/1 closeTimer(); } }); } /** * 关闭定时器 */ public void closeTimer(){ if (mDisposable != null) { mDisposable.dispose(); } }

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。