第六课：Android的异步任务（AsyncTask）

Android 提供了一套专门用于异步处理的类。即：AsyncTask 类。使用这个类可以为耗时程序开辟一个新线程进行处理，处理完时返回。

AsyncTask<Params, Progress, Result> 是一个抽象类，通常用于被集成。集成 AsyncTask 时需要制定如下三个泛型参数（传递的数据都是对应类型的数组，数组都是可变长的）：

Params：启动任务执行的输入参数的类型。对应 execute() 向 doInBackground() 的传递类型。

Progress：后台任务完成的进度值的类型。对应 publishProgress()  向 progressUpdate() 传递的类型。

Result：后台执行任务完成后返回结果的类型。对应doInBackground()的返回类型和传递给 onPostExecute() 的类型

AsyncTask 类主要用到的几个内部回调函数有以下四个，可以根据需要重写，其中 doInBackGround(Params...) 必须重写：

onPreExecute()：该方法将在执行实际的后台操作前被UI thread调用。可以在该方法中做一些准备工作，如在界面上显示一个进度条。

doInBackGround(Params... params)：将在onPreExecute 方法执行后马上执行，该方法运行在后台线程中。这里将主要负责执行那些很耗时的后台计算工作。可以调用 

publishProgress(Progress... values) 方法来更新实时的任务进度。该方法是抽象方法，子类必须实现。

onProgressUpdate(Progress... values)：在publishProgress方法被调用后，UI thread将调用这个方法从而在界面上展示任务的进展情况，例如通过一个进度条进行展示。

onPostExecute(Result result)：在doInBackground 执行完成后，onPostExecute 方法将被UI thread调用，后台的计算结果将通过该方法传递到UI thread。

回调逻辑关系如下：

回调逻辑关系说明：

1.主线程调用AsynTask子类实例的 execute(Params... params 方法后，首先会调用 onPreExecute() 方法。onPreExecute() 在主线程中运行，可以用来写一些开始提示代码或者进度条等。

2.之后启动新线程，调用 doInBackground(Params... params ) 方法，进行异步数据处理。

3.处理完毕之后异步线程结束，在主线程中调用 onPostExecute(Result result) 方法。onPostExecute(Result result)  可以进行一些结束提示处理。

使用 AsyncTask 只需要如下三步即可：

1.创建 AsyncTask 的子类，并为三个泛型参数指定类型。如果某个泛型参数不需要指定类型，则可将它指定为Void。

2.根据需要，实现 AsyncTask 的方法。

3.调用 AsyncTask 子类的实例的 execute(Params...)开始执行 AsyncTask 任务。

为了正确的使用AsyncTask类，必须遵守以下是几条准则：

1.必须在UI thread 中创建 AsyncTask 的实例。

2.必须在UI thread 中调用 AsyncTask 的实例的 execute() 方法。

3. AsyncTask 的 onPreExecute()、onPostExecute(Result result)、doInBackground(Params... params)、onProgressUpdate(Progress... values)这几个方法不该由程序员来调用，而是由 Android 系统负责调用。

4.每个 AsyncTask 只能被执行一次，多次调用时将会出现异常

例1：使用异步任务下载

public class AsyncTaskTest extends Activity
{
	private TextView show;

	@Override
	public void onCreate(Bundle savedInstanceState)
	{
		super.onCreate(savedInstanceState);
		setContentView(R.layout.main);
		show = (TextView) findViewById(R.id.show);
	}

	// 重写该方法，为界面的按钮提供事件响应方法
	public void download(View source) throws MalformedURLException
	{
		DownTask task = new DownTask(this);
		task.execute(new URL("http://www.crazyit.org/ethos.php"));
	}

	class DownTask extends AsyncTask<URL, Integer, String>
	{
		// 可变长的输入参数，与AsyncTask.exucute()对应
		ProgressDialog pdialog;
		// 定义记录已经读取行的数量
		int hasRead = 0;
		Context mContext;

		public DownTask(Context ctx)
		{
			mContext = ctx;
		}

		@Override
		protected String doInBackground(URL... params)
		{
			StringBuilder sb = new StringBuilder();
			try
			{
				URLConnection conn = params[0].openConnection();
				// 打开conn连接对应的输入流，并将它包装成BufferedReader
				BufferedReader br = new BufferedReader(
					new InputStreamReader(conn.getInputStream()
					, "utf-8"));
				String line = null;
				while ((line = br.readLine()) != null)
				{
					sb.append(line + "\n");
					hasRead++;
					publishProgress(hasRead);
				}
				return sb.toString();
			}
			catch (Exception e)
			{
				e.printStackTrace();
			}
			return null;
		}

		@Override
		protected void onPostExecute(String result)
		{
			// 返回HTML页面的内容
			show.setText(result);
			pdialog.dismiss();
		}

		@Override
		protected void onPreExecute()
		{
			pdialog = new ProgressDialog(mContext);
			// 设置对话框的标题
			pdialog.setTitle("任务正在执行中");
			// 设置对话框 显示的内容
			pdialog.setMessage("任务正在执行中，敬请等待...");
			// 设置对话框不能用“取消”按钮关闭
			pdialog.setCancelable(false);
			// 设置该进度条的最大进度值
			pdialog.setMax(202);
			// 设置对话框的进度条风格
			pdialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL);
			// 设置对话框的进度条是否显示进度
			pdialog.setIndeterminate(false);
			pdialog.show();
		}

		@Override
		protected void onProgressUpdate(Integer... values)
		{
			// 更新进度
			show.setText("已经读取了【" + values[0] + "】行！");
			pdialog.setProgress(values[0]);
		}
	}
}
           

源代码下载