開源專案 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 更新

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引以為傲的鏈式操作


    }
}