Interval操作符：用于创建Observable，跟TimerTask类似，用于周期性发送信息，是一个可以指定线程的TimerTask

首先添加类库

// RxAndroidcompile 'io.reactivex:rxandroid:1.2.1'// RxJavacompile 'io.reactivex:rxjava:1.2.4'

（1） 间隔时间3秒发送一次

private Subscription subscribe; private void start() { if (subscribe == null || subscribe.isUnsubscribed()) { subscribe = Observable.interval(3000, 3000, TimeUnit.MILLISECONDS)//延时3000 ，每间隔3000，时间单位 .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Action1<Long>() { @Override public void call(Long aLong) { Log.e("1234", "执行一次"); } }); } }

（2）取消订阅

private void stop() { if (subscribe != null && !subscribe.isUnsubscribed()) { subscribe.unsubscribe(); Log.e("1234", "停止"); } }

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