Android中AsyncTask使用詳解

import android.app.Activity; import android.os.AsyncTask; import android.os.Build; import android.os.Bundle; import android.util.Log; import android.view.View; import android.widget.Button; import android.widget.TextView;

import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL;

public class MainActivity extends Activity implements Button.OnClickListener {

TextView textView = null;
Button btnDownload = null;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    textView = (TextView)findViewById(R.id.textView);
    btnDownload = (Button)findViewById(R.id.btnDownload);
    Log.i("iSpring", "MainActivity -> onCreate, Thread name: " + Thread.currentThread().getName());
}

@Override
public void onClick(View v) {
    //要下載的文件地址
    String[] urls = {
            "http://blog.csdn.net/iispring/article/details/47115879",
            "http://blog.csdn.net/iispring/article/details/47180325",
            "http://blog.csdn.net/iispring/article/details/47300819",
            "http://blog.csdn.net/iispring/article/details/47320407",
            "http://blog.csdn.net/iispring/article/details/47622705"
    };

    DownloadTask downloadTask = new DownloadTask();
    downloadTask.execute(urls);
}

//public abstract class AsyncTask<Params, Progress, Result>
//在此例中，Params泛型是String類型，Progress泛型是Object類型，Result泛型是Long類型
private class DownloadTask extends AsyncTask<String, Object, Long> {
    @Override
    protected void onPreExecute() {
        Log.i("iSpring", "DownloadTask -> onPreExecute, Thread name: " + Thread.currentThread().getName());
        super.onPreExecute();
        btnDownload.setEnabled(false);
        textView.setText("開始下載...");
    }

    @Override
    protected Long doInBackground(String... params) {
        Log.i("iSpring", "DownloadTask -> doInBackground, Thread name: " + Thread.currentThread().getName());
        //totalByte表示所有下載的文件的總字節數
        long totalByte = 0;
        //params是一個String數組
        for(String url: params){
            //遍歷Url數組，依次下載對應的文件
            Object[] result = downloadSingleFile(url);
            int byteCount = (int)result[0];
            totalByte += byteCount;
            //在下載完一個文件之后，我們就把階段性的處理結果發布出去
            publishProgress(result);
            //如果AsyncTask被調用了cancel()方法，那么任務取消，跳出for循環
            if(isCancelled()){
                break;
            }
        }
        //將總共下載的字節數作為結果返回
        return totalByte;
    }

    //下載文件后返回一個Object數組：下載文件的字節數以及下載的博客的名字
    private Object[] downloadSingleFile(String str){
        Object[] result = new Object[2];
        int byteCount = 0;
        String blogName = "";
        HttpURLConnection conn = null;
        try{
            URL url = new URL(str);
            conn = (HttpURLConnection)url.openConnection();
            InputStream is = conn.getInputStream();
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            byte[] buf = new byte[1024];
            int length = -1;
            while ((length = is.read(buf)) != -1) {
                baos.write(buf, 0, length);
                byteCount += length;
            }
            String respone = new String(baos.toByteArray(), "utf-8");
            int startIndex = respone.indexOf("<title>");
            if(startIndex > 0){
                startIndex += 7;
                int endIndex = respone.indexOf("</title>");
                if(endIndex > startIndex){
                    //解析出博客中的標題
                    blogName = respone.substring(startIndex, endIndex);
                }
            }
        }catch(MalformedURLException e){
            e.printStackTrace();
        }catch(IOException e){
            e.printStackTrace();
        }finally {
            if(conn != null){
                conn.disconnect();
            }
        }
        result[0] = byteCount;
        result[1] = blogName;
        return result;
    }

    @Override
    protected void onProgressUpdate(Object... values) {
        Log.i("iSpring", "DownloadTask -> onProgressUpdate, Thread name: " + Thread.currentThread().getName());
        super.onProgressUpdate(values);
        int byteCount = (int)values[0];
        String blogName = (String)values[1];
        String text = textView.getText().toString();
        text += "\n博客《" + blogName + "》下載完成，共" + byteCount + "字節";
        textView.setText(text);
    }

    @Override
    protected void onPostExecute(Long aLong) {
        Log.i("iSpring", "DownloadTask -> onPostExecute, Thread name: " + Thread.currentThread().getName());
        super.onPostExecute(aLong);
        String text = textView.getText().toString();
        text += "\n全部下載完成，總共下載了" + aLong + "個字節";
        textView.setText(text);
        btnDownload.setEnabled(true);
    }

    @Override
    protected void onCancelled() {
        Log.i("iSpring", "DownloadTask -> onCancelled, Thread name: " + Thread.currentThread().getName());
        super.onCancelled();
        textView.setText("取消下載");
        btnDownload.setEnabled(true);
    }
}

}</pre>

點擊下載按鈕后，界面如下所示：

控制臺輸出如下所示：

下面對以上代碼進行一下說明。

1. 我們在MainActivity中定義了內部類DownloadTask，DownloadTask繼承自AsyncTask，在該例中，Params泛型是String類型，Progress泛型是Object類型，Result泛型是Long類型。

2. 我們定義了一個Url字符串數組，將該數組傳遞給AsyncTask的execute方法，用于異步執行task。

3. 在執行了downloadTask.execute(urls)之后，AsyncTask會自動回調onPreExecute方法，在該方法中我們將textView設置為“開始下載…”幾個字，告知用戶即將執行下載操作。通過控制臺輸出我們也可以看出該方法是在主線程中執行的。

4. 在執行了onPreExecute方法之后，AsyncTask會回調doInBackground方法，該方法中的輸入參數是String類型的不定長數組，此處的String就對應著Params泛型類型，我們在該方法中遍歷Url數組，依次下載對應的文件，當我們下載完一個文件，就相當于我們階段性地完成了一部分任務，我們就通過調用publishProgress方法將階段性處理結果發布出去。在此例中我們將階段性的處理結果定義為Object類型，即Progress泛型類型。通過控制臺輸出我們可以看出doInBackground方法是運行在新的工作線程”AsyncTask #1”中的，AsyncTask的工作線程都是以”AsyncTask #”然后加上數字作為名字。當所有文件下載完成后，我們就可以通過totalSize返回所有下載的字節數，返回值類型為Long，對應著AsyncTask中的Result泛型類型。

5. 在doInBackground方法中，每當下載完一個文件，我們就會調用publishProgress方法發布階段性結果，之后AsyncTask會回調onProgressUpdate方法，在此例中，onProgressUpdate的參數為Object類型，對應著AsyncTask中的Progress泛型類型。通過控制臺輸出我們可以發現，該方法是在主線程中調用的，在該方法中我們會通過textView更新UI，告知用戶哪個文件下載完成了，這樣用戶體驗相對友好。

6. 在整個doInBackground方法執行完畢后，AsyncTask就會回調onPostExecute方法，在該方法中我們再次通過textView更新UI告知用戶全部下載任務完成了。

7. 在通過execute方法執行了異步任務之后，可以通過AsyncTask的cancel方法取消任務，取消任務后AsyncTask會回調onCancelled方法，這樣不會再調用onPostExecute方法。

在使用Android的過程中，有以下幾點需要注意：

• AsyncTask的實例必須在主線程中創建。

• AsyncTask的execute方法必須在主線程中調用。

• onPreExecute()、onPostExecute(Result),、doInBackground(Params…) 和 onProgressUpdate(Progress…)這四個方法都是回調方法，Android會自動調用，我們不應自己調用。

• 對于一個AsyncTack的實例，只能執行一次execute方法，在該實例上第二次執行execute方法時就會拋出異常。

通過上面的示例，大家應該熟悉了AsyncTask的使用流程。我們上面提到，對于某個AsyncTask實例，只能執行一次execute方法，如果我們想并行地執行多個任務怎么辦呢？我們可以考慮實例化多個AsyncTask實例，然后分別調用各個實例的execute方法，為了探究效果，我們將代碼更改如下所示：