1. 程式人生 > >Android實現非同步的幾種方法

Android實現非同步的幾種方法

在Android專案中,有經驗的開發人員都知道,一些耗時的IO操作等都必須在子執行緒中去操作,那麼可以有哪些方法來開啟子執行緒呢,一般可以使用Java中自帶的幾種方法,也可以使用Andorid特有的一些類。

用Java來實現非同步

主要有兩種方法來實現非同步,繼承Thread類和實現Runnable介面

1.繼承Thread類

先上程式碼

public class MyThread extends Thread {

    private String name;

    public MyThread(String name){
        this.name = name;
    }

    @Override
public void run() { System.out.println(name); } } public class MainTest { public static void main(String[] args){ MyThread myThread1 = new MyThread("myThread1"); MyThread myThread2 = new MyThread("myThread2"); MyThread myThread3 = new MyThread("myThread3"
); myThread1.start(); myThread2.start(); myThread3.start(); } }

MyThread繼承自Thread類,重寫run()方法,在run()方法中寫上子執行緒需要執行的任務就可以了。然後在測試的main()方法中new MyThread()。再呼叫start()方法。這樣就完成了使用繼承Thread,來實現子執行緒從建立到執行的整個過程。

2.實現Runnable介面

public class MyThreadRunnable implements Runnable
{
private String name; public MyThreadRunnable(String name){ this.name = name; } @Override public void run() { System.out.println(name); } } public class MainTest { public static void main(String[] args){ MyThreadRunnable r1 = new MyThreadRunnable("r1"); MyThreadRunnable r2 = new MyThreadRunnable("r1"); MyThreadRunnable r3 = new MyThreadRunnable("r1"); Thread t1 = new Thread(r1); Thread t2 = new Thread(r2); Thread t3 = new Thread(r3); t1.start(); t2.start(); t3.start(); } }

MyThreadRunnable實現Runnable介面,並且在run()方法中實現自己的任務,這跟前面的很類似,只是後面要開啟執行緒的時候不僅需要new MyThreadRunnable()而且還需要new Thread()並且把前面的物件傳入,再通過Thread呼叫start()方法來啟動執行緒。
上面的方法來開啟子執行緒,還可以用靜態內部類來實現,這樣程式碼看起來會更加簡潔。

new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("xxxx");
            }
        }).start();

從程式碼層面來看,繼承Thread看起來更加方便,但是java是單繼承的,在實際生產中,一般都需要某個類,所以實現Runnable的用法會多一點。

使用Android特有的方法來實現非同步

1.AsyncTask

public class MainActivity extends Activity {


    private ProgressBar mProgressBar;
    private ImageView mImageView;

    @Override
    public void onCreate(Bundle savedInstanceState, PersistableBundle persistentState) {
        super.onCreate(savedInstanceState, persistentState);


        MyAsyncTask myAsyncTask = new MyAsyncTask();
        myAsyncTask.execute("www.baidu.com/xxx.jpg");
    }

    class MyAsyncTask extends AsyncTask<String, Integer, Bitmap>{

        @Override
        protected void onPreExecute() {
            //這裡是開始執行緒之前執行的,是在UI執行緒
            mProgressBar.setMax(100);
            super.onPreExecute();
        }

        @Override
        protected Bitmap doInBackground(String... params) {
            //這是在後臺子執行緒中執行的
            Bitmap bitmap = null;
            try {
                URL url = new URL(params[0]);
                HttpURLConnection connection = (HttpURLConnection) url.openConnection();
                InputStream inputStream = connection.getInputStream();
                bitmap = BitmapFactory.decodeStream(inputStream);
                publishProgress(70);//這裡是更新進度
                inputStream.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
            return bitmap;
        }

        @Override
        protected void onCancelled() {
            //當任務被取消時回撥
            super.onCancelled();
        }

        @Override
        protected void onProgressUpdate(Integer... values) {
            super.onProgressUpdate(values);
            //更新進度
            mProgressBar.setProgress(values[0]);
        }

        @Override
        protected void onPostExecute(Bitmap bitmap) {
            super.onPostExecute(bitmap);
            //當任務執行完成是呼叫,在UI執行緒
            mImageView.setImageBitmap(bitmap);
        }
    }

}

MyAsyncTask基礎自AsyncTask,三個泛型分別為,String:是傳入引數型別,可以傳多個,Integer:是進度顯示的引數型別,也可以傳多個,Bitmap:是任務執行完的返回型別,這裡就是返回一個Bitmap。
使用AsyncTask來實現非同步的有點就是簡單便捷,各個過程都有明確的回撥,過程可控。但是缺點就是要是執行多個非同步,就會變得很複雜。

2.Handler

public class HandlerTestActivity extends Activity {

    Handler mHandler = new Handler(){
        @Override
        public void handleMessage(Message msg) {
            super.handleMessage(msg);
            int what = msg.what;
            if(what == 0){
                //在主執行緒中需要執行的操作,一般是UI操作
            }
        }
    };

    @Override
    public void onCreate(Bundle savedInstanceState, PersistableBundle persistentState) {
        super.onCreate(savedInstanceState, persistentState);

        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                //在子執行緒中執行任務,執行完成或需要通知UI執行緒時呼叫以下方法
                mHandler.sendEmptyMessage(0);
            }
        });
        thread.start();
    }
}

上面就是最簡單的使用Handler完成子執行緒和主執行緒的通訊(子執行緒發訊息給主執行緒)

public class LooperThreadActivity extends Activity {

    private Handler mHandler = null;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        new MyThread().start();
        //發訊息到目標子執行緒
        mHandler.obtainMessage(0).sendToTarget();

    }

    class MyThread extends Thread{

        @Override
        public void run() {
            super.run();
            //1.建立訊息迴圈,初始化Looper
            Looper.prepare();
            mHandler = new Handler(){
                @Override
                public void handleMessage(Message msg) {
                    super.handleMessage(msg);
                    int what = msg.what;
                    if(what == 0){
                        //
                    }
                }
            };
            //啟動訊息迴圈
            Looper.loop();
        }
    }
}

上面是主執行緒發訊息給子執行緒,也是比較類似的,只不過在子執行緒中,需要初始化Looper.prepare()和Looper.loop()。

RxJava

這個比較新,學習路線比較陡峭,但是一旦入門,使用起來真的很爽。

public class RxJavaTestActivity extends Activity {

    private ImageView mImageView;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        Observable.just("")
                .map(new Func1<String, Bitmap>() {
                    @Override
                    public Bitmap call(String s) {
                        //可以在這裡執行耗時操作,比如下載網路圖片,然後轉化為Bitmap
                        return null;
                    }
                }).subscribeOn(Schedulers.io())//把工作執行緒指定為了IO執行緒
                .observeOn(AndroidSchedulers.mainThread())//把回撥執行緒指定為了UI執行緒
                .subscribe(new Action1<Bitmap>() {
                    @Override
                    public void call(Bitmap bitmap) {
                        //這裡是在UI執行緒,這裡顯示了圖片
                        mImageView.setImageBitmap(bitmap);
                    }
                });
    }
}

這裡是最簡單的使用了RxJava,來實現非同步操作。RxJava還有更多更強大的功能等你去發現。