開源項(xiàng)目 RxJava-Android-Samples确镊，這里一共介紹了十八種RxJava2的使用場(chǎng)景，這一系列文章主要參考該項(xiàng)目進(jìn)行蕾域。
我們經(jīng)常會(huì)在后臺(tái)線程中去做一些耗時(shí)的操作旨巷，比如去網(wǎng)絡(luò)取數(shù)據(jù)采呐，處理的方法有
HandlerThread斧吐、Thread、Service煤率、IntentService洋只、AysncTask识虚、AsyncQueryHandler。對(duì)于它們的優(yōu)異舷礼，這里就不展開說(shuō)了妻献，戰(zhàn)友們自行Google吧～
當(dāng)獲取到數(shù)據(jù)育拨，更新UI頁(yè)面的時(shí)候熬丧，一般是不允許在其他線程直接操作的析蝴。下面我們來(lái)看下怎么在線程中操作UI界面闷畸。
方法一：Handler
子線程調(diào)用Handler的sendMessage(message)發(fā)送事件佑菩。
mHandler = new Handler() {
@Override
public void handleMessage(Message msg) {
//操作界面
myText.setText( 來(lái)自網(wǎng)絡(luò)的信息);
super.handleMessage(msg);
}
};
public class MyThread extends Thread {
public void run() {
? ? ? // 耗時(shí)操作
? ? ? ?loadNetWork();
Message msg = new Message();
mHandler.sendMessage(msg);//向Handler發(fā)送消息殿漠，
}
}
方法二：View.post（Runnable )
public void onClick( View v ) {
new Thread( new Runnable() {
public void run() {
// 耗時(shí)操作
? ? ? ? ? ? loadNetWork();
? myText.( new Runnable() {
myText.setText( 來(lái)自網(wǎng)絡(luò)的信息);
});
}
}).start();
}
方法三：Activity.runOnUiThread（Runnable )
與view.post類似
public void onClick( View v ) {
new Thread( new Runnable() {
public void run() {
// 耗時(shí)操作
? ? ? ? ? ? loadNetWork();
? Activity.runOnUiThread.( new Runnable() {
myText.setText( 來(lái)自網(wǎng)絡(luò)的信息);
});
}
}).start();
}
方法四：AsyncTask
//UI線程中執(zhí)行
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] );//后臺(tái)耗時(shí)操作
}
protected void onPostExecute( String result ) {
myText.setText( result ); //得到來(lái)自網(wǎng)絡(luò)的信息刷新頁(yè)面
}
private class LoadTask extends Anew DownloadImageTask().execute( "www.linuxidc.com" );
private class LoadTask extends AsyncTask {
protected String doInBackground( String... url ) {
return loadDataFormNetwork( url[0] );//后臺(tái)耗時(shí)操作
}
protected void onPostExecute( String result ) {
myText.setText( result ); //得到來(lái)自網(wǎng)絡(luò)的信息刷新頁(yè)面
} syncTask {
protected String doInBackground( String... url ) {
return loadDataFormNetwork( url[0] );//后臺(tái)耗時(shí)操作
}
protected void onPostExecute( String result ) {
myText.setText( result ); //得到來(lái)自網(wǎng)絡(luò)的信息刷新頁(yè)面
}
RxJava 實(shí)現(xiàn)后臺(tái)執(zhí)行耗時(shí)操作一忱，實(shí)時(shí)通知 UI 更新
我們知道rxjava默認(rèn)的上下游是在同一個(gè)線程工作谭确，這樣明顯不能滿足我們的要求菇夸，這個(gè)時(shí)候我們就需要用到rxjava的線程調(diào)度了庄新。請(qǐng)參考
Android拾萃 - RxJava最簡(jiǎn)單的入門（一）
Android拾萃 - RxJava操作符列表和響應(yīng)類型（二）
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, "已經(jīng)在下載中择诈，請(qǐng)稍后繼續(xù)羞芍。", Toast.LENGTH_SHORT).show();
return;
}
startDownload();
}
});
}
private void startDownload() {
//Observable 對(duì)應(yīng)的上游類型是ObservableOnSubscribe 我們需要發(fā)射數(shù)據(jù)荷科，所以實(shí)現(xiàn)了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 對(duì)應(yīng)的下游類型是Observer
Observer observer = new Observer() {
//rx2 新加入的方法，在訂閱后發(fā)送數(shù)據(jù)之前狞贱，
//回首先調(diào)用這個(gè)方法蝎毡，而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;
}
}
};
//建立訂閱關(guān)系
download.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(observer);//把這段代碼連起來(lái)寫就成了RxJava引以為傲的鏈?zhǔn)讲僮?
//方式二
//Observable 對(duì)應(yīng)的下游類型是Consumer
Consumer consumer = new Consumer<Integer>() {
@Override
public void accept(Integer integer) throws Exception {
mProgressBar.setProgress((Integer) integer);
}
};
//建立訂閱關(guān)系
// download.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(consumer);//把這段代碼連起來(lái)寫就成了RxJava引以為傲的鏈?zhǔn)讲僮?
}
}
device-2017-09-10-025027.png
