Android多線程技術(shù)選型最全指南

new Thread(new Runnable() {      @Override      public void run() {
      }  }).start();

//runnable->presenter->viewpublic class Presenter {    //持有view引用    private IView view;    public Presenter(IView v){        this.view = v;    }    public void doSomething(String[] args){        new Thread(new Runnable() {            @Override            public void run() {                /**                ** 持有presenter引用                **/                //do something            }        }).start();    }    public static interface IView{}}

static HandlerThread thread = new HandlerThread("test");static {    thread.start();}
public void testHandlerThread(){    Handler handler = new Handler(thread.getLooper());    handler.post(new Runnable() {        @Override        public void run() {                //do something        }    });????//如果不需要了就remove?handler's?message    handler.removeCallbacksAndMessages(null);}
public void test(){    //如果我還想利用HandlerThread，但是已經(jīng)丟失了handler的句柄，那么我們利用handler thread再構(gòu)建一個(gè)handler    Handler handler = new Handler(thread.getLooper());    handler.post(new Runnable() {        @Override        public void run() {           //do something        }    });}

public static class DemoThread extends Thread{    private LinkedBlockingQueue queue  = new LinkedBlockingQueue<>();
  @Override  public void run() {    super.run();      while(true){        if(!queue.isEmpty()){           Runnable runnable;           synchronized (this){               runnable = queue.poll();           }           if(runnable!= null) {                runnable.run();???????????}         }      }??}
  public synchronized void post(Runnable runnable){    queue.add(runnable);  }
  public synchronized void clearAllMessage(){    queue.clear();  }
  public synchronized void clearOneMessage(Runnable runnable){    for(Runnable runnable1 : queue){      if(runnable == runnable1){        queue.remove(runnable);       }      }    }   }
  public void testDemoThread(){    DemoThread thread = new DemoThread();    thread.start();     //發(fā)一個(gè)消息     Runnable r = new Runnable() {        @Override????????public?void?run()?{           }        };     thread.post(r);    //不想執(zhí)行了。。。。刪掉    thread.clearOneMessage(r);  }

AsyncTask.execute(new Runnable() {  @Override  public void run() {  }});

@MainThreadpublic static void execute(Runnable runnable) {     sDefaultExecutor.execute(runnable);?}

AsyncTask asyncTask = new AsyncTask() {    @Override    protected Object doInBackground(Object[] objects) {?????????return?null;    }
    @Override    protected void onPostExecute(Object o) {         //1.提供了后臺(tái)線程切換回主線程的方法           super.onPostExecute(o);        }     };
????//2.可以隨時(shí)取消???asyncTask.cancel(true);

public class YoutubePlayerActivity extends Activity {    private Subscription subscription;    public void setUnSubscribeListner(){        unsubscribeButton.setOnClickListener(new View.OnClickListener() {            @Override            public void onClick(View v) {                subscription = Observable.create(new Observable.OnSubscribe() {                    @Override                    public void call(Subscribersuper Void> subscriber) {                        try {                            //在這里我們做取消訂閱的API， http                            API api = new API();                            api.unSubscribe();                        }                        catch (Exception e){                            subscriber.onError(e);                        }                        subscriber.onNext(null);                        subscriber.onCompleted();                    }                })
                 .subscribeOn(Schedulers.io())                 .observeOn(AndroidSchedulers.mainThread())                 .subscribe(new Action1() {                      @Override                      public void call(Void aVoid) {                          //API call成功！，在這里更新訂閱button的ui                          unsubscribeButton.toggleSubscriptionStatus();                      }?????????????????});            }        });    }    @Override    protected void onDestroy() {        super.onDestroy();       //onDestroy 里面對(duì)RxJava stream進(jìn)行unsubscribe，防止內(nèi)存泄漏        subscription.unsubscribe();    }}

API?api?=?new?API();api.unSubscribe();