Android两种轮询的实现方法
Android两种轮询的简单写法，供大家参考，具体内容如下
publicvoidstartPolling(){
subscriber=Observable.interval(0,POLLING_INTERVAL,TimeUnit.MILLISECONDS).
doOnNext(newAction1(){
@Override
publicvoidcall(LongaLong){
doPolling().
subscribeOn(Schedulers.io()).
observeOn(AndroidSchedulers.mainThread()).
subscribe(newSubscriber(){
@Override
publicvoidonCompleted(){
}
@Override
publicvoidonError(Throwablee){
Log.d(TAG,"onError");
}
@Override
publicvoidonNext(Stringresponse){
handleResponse(response);
}
});
}
}).subscribe();
}
publicvoidstopPolling(){
if(!subscriber.isUnsubscribed()){
subscriber.unsubscribe();
}
}
privateObservabledoPolling(){
returnObservable.create(newObservable.OnSubscribe(){
@Override
publicvoidcall(Subscribersubscriber){
//dowork
subscriber.onNext(response);
subscriber.onCompleted();
}
});
}
在Activity的生命周期里分别调用start和stop方法，解除轮询绑定，避免内存泄漏。
其它简单的轮询方法还有利用handler的postDelay机制实现
@Override
publicvoidhandleMsg(Messagemsg){
switch(msg.what){
caseMSG_POLLING:
doPolling(false);
break;
...
...
}
}
privatevoiddoPolling(BooleanisFirst){
if(isFirst){
mHandler.removeMessages(MSG_POLLING);
mHandler.sendEmptyMessageDelayed(MSG_POLLING,POLLING_INTERVAL);
return;
}
doWork();//asynnetwork
mHandler.sendEmptyMessageDelayed(MSG_POLLING,POLLING_INTERVAL);
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。