Android拾萃 - RxJava实战（后台执行耗时操作，实
2017-09-10 本文已影响299人
三也视界
开源项目 RxJava-Android-Samples，这里一共介绍了十八种RxJava2的使用场景，这一系列文章主要参考该项目进行。
我们经常会在后台线程中去做一些耗时的操作，比如去网络取数据，处理的方法有
HandlerThread、Thread、Service、IntentService、AysncTask、AsyncQueryHandler。对于它们的优异，这里就不展开说了，战友们自行Google吧～
当获取到数据，更新UI页面的时候，一般是不允许在其他线程直接操作的。下面我们来看下怎么在线程中操作UI界面。
方法一：Handler
子线程调用Handler的sendMessage(message)发送事件。
mHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
//操作界面
myText.setText( 来自网络的信息);
super.handleMessage(msg);
}
};
public class MyThread extends Thread {
public void run() {
// 耗时操作
loadNetWork();
Message msg = new Message();
mHandler.sendMessage(msg);//向Handler发送消息，
}
}
方法二：View.post（Runnable )
public void onClick( View v ) {
new Thread( new Runnable() {
public void run() {
// 耗时操作
loadNetWork();
myText.( new Runnable() {
myText.setText( 来自网络的信息);
});
}
}).start();
}
方法三：Activity.runOnUiThread（Runnable )
与view.post类似
public void onClick( View v ) {
new Thread( new Runnable() {
public void run() {
// 耗时操作
loadNetWork();
Activity.runOnUiThread.( new Runnable() {
myText.setText( 来自网络的信息);
});
}
}).start();
}
方法四：AsyncTask
//UI线程中执行
new DownloadImageTask().execute( "www.linuxidc.com" );
new DownloadImageTask().execute( "www.linuxidc.com" );
private class LoadTask extends AsyncTask {
protected String doInBackground( String... url ) {
return loadDataFormNetwork( url[0] );//后台耗时操作
}
protected void onPostExecute( String result ) {
myText.setText( result ); //得到来自网络的信息刷新页面
}
private class LoadTask extends Anew DownloadImageTask().execute( "www.linuxidc.com" );
private class LoadTask extends AsyncTask {
protected String doInBackground( String... url ) {
return loadDataFormNetwork( url[0] );//后台耗时操作
}
protected void onPostExecute( String result ) {
myText.setText( result ); //得到来自网络的信息刷新页面
} syncTask {
protected String doInBackground( String... url ) {
return loadDataFormNetwork( url[0] );//后台耗时操作
}
protected void onPostExecute( String result ) {
myText.setText( result ); //得到来自网络的信息刷新页面
}
RxJava 实现后台执行耗时操作，实时通知 UI 更新
我们知道rxjava默认的上下游是在同一个线程工作，这样明显不能满足我们的要求，这个时候我们就需要用到rxjava的线程调度了。请参考
Android拾萃 - RxJava最简单的入门（一）
Android拾萃 - RxJava操作符列表和响应类型（二）
Android拾萃 - RxJava操作符的使用（三）
public class BackgroundActivity extends AppCompatActivity {
private TextView mTvDownload;
private ProgressBar mProgressBar;
private Disposable disposable;
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_background);
mTvDownload = (TextView) findViewById(R.id.start_download);
mProgressBar = (ProgressBar) findViewById(R.id.progress);
mProgressBar.setMax(100);
mTvDownload.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
if (disposable != null && !disposable.isDisposed()) {
Toast.makeText(BackgroundActivity.this, "已经在下载中，请稍后继续。", Toast.LENGTH_SHORT).show();
return;
}
startDownload();
}
});
}
private void startDownload() {
//Observable 对应的上游类型是ObservableOnSubscribe 我们需要发射数据，所以实现了ObservableEmitter方法
Observable download = Observable.create(new ObservableOnSubscribe() {
@Override
public void subscribe(@NonNull ObservableEmitter e) throws Exception {
for (int i=0; i<=100; i++){
if (i%10 == 0) {
try{
Thread.sleep(400);//模拟下载的操作
}catch (Exception e1) {
e1.printStackTrace();
if (!e.isDisposed()) {
e.onError(e1);
}
}
if ((disposable != null && !disposable.isDisposed()) || disposable == null)
e.onNext(i);
}
}
e.onComplete();
}
});
//方式一
//Observable 对应的下游类型是Observer
Observer observer = new Observer() {
//rx2 新加入的方法，在订阅后发送数据之前，
//回首先调用这个方法，而Disposable可用于取消订阅
@Override
public void onSubscribe(@NonNull Disposable d) {
disposable = d;
}
@Override
public void onNext(@NonNull Object o) {
mProgressBar.setProgress((Integer) o);
}
@Override
public void onError(@NonNull Throwable e) {
}
@Override
public void onComplete() {
Toast.makeText(BackgroundActivity.this, " 下载完成！", Toast.LENGTH_SHORT).show();
if (disposable != null && !disposable.isDisposed()) {
disposable.dispose();
disposable = null;
}
}
};
//建立订阅关系
download.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(observer);//把这段代码连起来写就成了RxJava引以为傲的链式操作
//方式二
//Observable 对应的下游类型是Consumer
Consumer consumer = new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
mProgressBar.setProgress((Integer) integer);
}
};
//建立订阅关系
// download.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(consumer);//把这段代码连起来写就成了RxJava引以为傲的链式操作
}
}
device-2017-09-10-025027.png
