Android两种轮询的实现方法
Android 两种轮询的简单写法,供大家参考,具体内容如下
public void startPolling() { subscriber = Observable.interval(0, POLLING_INTERVAL, TimeUnit.MILLISECONDS). doOnNext(new Action1<Long>() { @Override public void call(Long aLong) { doPolling(). subscribeOn(Schedulers.io()). observeOn(AndroidSchedulers.mainThread()). subscribe(new Subscriber<String>() {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable e) { Log.d(TAG, 'onError');}@Overridepublic void onNext(String response) { handleResponse(response);} }); } }).subscribe();}public void stopPolling() { if (!subscriber.isUnsubscribed()) { subscriber.unsubscribe(); }}private Observable<Param> doPolling() { return Observable.create(new Observable.OnSubscribe<Param>() { @Override public void call(Subscriber<? super Param> subscriber) { //do work subscriber.onNext(response); subscriber.onCompleted(); } });}
在Activity的生命周期里分别调用start和stop方法,解除轮询绑定,避免内存泄漏。
其它简单的轮询方法还有利用handler的postDelay机制实现
@Overridepublic void handleMsg(Message msg) { switch (msg.what) { case MSG_POLLING: doPolling(false); break; ... ... }}private void doPolling(Boolean isFirst) { if(isFirst) { mHandler.removeMessages(MSG_POLLING); mHandler.sendEmptyMessageDelayed(MSG_POLLING, POLLING_INTERVAL); return; } doWork(); //asyn network mHandler.sendEmptyMessageDelayed(MSG_POLLING, POLLING_INTERVAL);}
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持好吧啦网。
相关文章:
1. 如何在Django中使用聚合的实现示例2. 解决导入django_filters不成功问题No module named 'django_filter'3. Django查询优化及ajax编码格式原理解析4. Django Admin设置应用程序及模型顺序方法详解5. IntelliJ IDEA快速创建getter和setter方法6. jsp+mysql实现网页的分页查询7. 解决django 多个APP时 static文件的问题8. Android自定义TextBanner实现自动滚动9. Django:使用filter的pk进行多值查询操作10. 使用Django实现把两个模型类的数据聚合在一起