android中的耗时操作需要放在子线程中去执行
asynctask是对Handler和和线程池的封装，直接使用比THread效率更加的高效因为封装了线程池，比我们每次直接new Thread效率更高
需要注意的是onPreExecute在主线程中执行，一般用来显示提示视图
doInBackground在分线程中执行，完成任务的主要工作
onPostExecute在doInBackGround（）执行完成在主线程中执行，用来更新界面
publishProgress 在子线程中发布当前的进度，进度发布之后就会触发主线程调用onProgressUpdate函数被调用
现在我们来做一个简单的测试用例
我们通过asynTask下下载一个apk
首先我们先搭建一个apk的下载环境
我们在自己的电脑下载一个tomacat，启动tomacat ，把需要下载的apk放置在tomacat的root目录下
E:\apache-tomcat-6.0.45-windows-x64\apache-tomcat-6.0.45-windows-x64\apache-tomcat-6.0.45\webapps\ROOT
我们让手机和当前的电脑在同一个局域网内
package im.weiyuan.com.myasynctask;import android.app.ProgressDialog;import android.content.Intent;import android.net.Uri;import android.os.AsyncTask;import android.os.SystemClock;import android.support.v7.app.AlertDialog;import android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.util.Log;import android.view.View;import android.widget.Button;import android.widget.Toast;import java.io.File;import java.io.FileOutputStream;import java.io.InputStream;import java.net.HttpURLConnection;import java.net.URL;public class MainActivity extends AppCompatActivity { Button btn_main_down; private File apkFile; private ProgressDialog dialog; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); Log.i("123456","onCreate is called"); btn_main_down = (Button) findViewById(R.id.btn_main_down); btn_main_down.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { MyAsyncTask task = new MyAsyncTask(); /** * 自己电脑上的apk的下载地址 * * **/ task.execute("http://10.12.8.8:8080/EncryptCardManager.apk"); } }); } public class MyAsyncTask extends AsyncTask { /** * 在主线程中进行初始化视图的操作 * */ @Override protected void onPreExecute() { super.onPreExecute(); Log.e("123456:", "onPreExecute is called:"); dialog = new ProgressDialog(MainActivity.this); dialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL); dialog.show(); //准备用于保存APK文件的File对象 : /storage/sdcard/Android/package_name/files/xxx.apk apkFile = new File(getExternalFilesDir(null), "update.apk"); } /**** * 分线程中进行联网操作，下载apk * */ @Override protected String doInBackground(String... params) { try { Log.e("123456:", "doInBackground is called:"+params[0]); //1. 得到连接对象 String path = params[0]; URL url = new URL(path); HttpURLConnection connection = (HttpURLConnection) url.openConnection(); //2. 设置 //connection.setRequestMethod("GET"); connection.setConnectTimeout(5000); connection.setReadTimeout(10000); //3. 连接 connection.connect(); //4. 请求并得到响应码200 int responseCode = connection.getResponseCode(); if(responseCode==200) { //设置dialog的最大进度 dialog.setMax(connection.getContentLength()); //5. 得到包含APK文件数据的InputStream InputStream is = connection.getInputStream(); //6. 创建指向apkFile的FileOutputStream FileOutputStream fos = new FileOutputStream(apkFile); //7. 边读边写 byte[] buffer = new byte[1024]; int len = -1; while((len=is.read(buffer))!=-1) { fos.write(buffer, 0, len); //8. 显示下载进度 //dialog.incrementProgressBy(len); //在分线程中, 发布当前进度 publishProgress(len); //休息一会(模拟网速慢) //Thread.sleep(50); SystemClock.sleep(10); } fos.close(); is.close(); } //9. 下载完成, 关闭, 进入3) connection.disconnect(); } catch (Exception e) { e.printStackTrace(); Log.e("123456 exception:",e.getMessage()); return e.getMessage(); } return "apk download sucess"; } /** * 在主线程中更新进度条 * */ @Override protected void onProgressUpdate(Integer... values) { super.onProgressUpdate(values); dialog.incrementProgressBy(values[0]); } /*** * apk下载完成，在主线程中关闭进度条 * */ @Override protected void onPostExecute(String s) { super.onPostExecute(s); dialog.dismiss(); if("apk download sucess".equalsIgnoreCase(s)){ Toast.makeText(MainActivity.this,"apk 下载成功",Toast.LENGTH_LONG).show(); installAPK(); }else { Toast.makeText(MainActivity.this,"apk下载失败"+s,Toast.LENGTH_LONG).show(); } } } /** * 启动安装APK */ private void installAPK() { Intent intent = new Intent("android.intent.action.INSTALL_PACKAGE"); intent.setDataAndType(Uri.fromFile(apkFile), "application/vnd.android.package-archive"); startActivity(intent); }}
总结下：在去背景世联面试的时候，就问题到了我这个问题
asynTask最大的优点是，子线程执行完成后可以把线程执行完成后的结果通过给主线程
2、接下来我们有这样的一个需求，当如果doInBackgroud执行的任务必须在10秒之内执行完成，如果10秒之内没有执行完成，我们就取消任务
如何达到该需求了AsyncTask提供了一个get函数，该函数值阻塞的，如果放在UI线程中会阻塞UI
package im.weiyuan.com.myasynctask;import android.app.ProgressDialog;import android.content.Intent;import android.net.Uri;import android.os.AsyncTask;import android.os.SystemClock;import android.support.v7.app.AlertDialog;import android.support.v7.app.AppCompatActivity;import android.os.Bundle;import android.util.Log;import android.view.View;import android.widget.Button;import android.widget.Toast;import java.io.File;import java.io.FileOutputStream;import java.io.InputStream;import java.net.HttpURLConnection;import java.net.URL;import java.util.concurrent.ExecutionException;import java.util.concurrent.TimeUnit;import java.util.concurrent.TimeoutException;public class MainActivity extends AppCompatActivity { Button btn_main_down; private File apkFile; private ProgressDialog dialog; private MyAsyncTask task; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); task = new MyAsyncTask(); Log.i("123456","onCreate is called"); btn_main_down = (Button) findViewById(R.id.btn_main_down); btn_main_down.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { /** * 自己电脑上的apk的下载地址 * * **/ task.execute("http://10.12.8.8:8080/EncryptCardManager.apk"); } }); new Thread(new Runnable() { @Override public void run() { try { task.get(10000, TimeUnit.MILLISECONDS); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } catch (TimeoutException e) { /**** * * 如果doInBackGround代码执行的时间超过10秒就会抛出这个异常 * */ e.printStackTrace(); Log.d("123456","TimeoutException"); /** * 调用cancel函数取消正在执行的doInBackGround任务，这个时候正在执行的任务被取消，就给抛出异常 * * doInBackGround任务被取消，不会在调用onPostExecute方法 * * 调用cancel在主线程就会调用onCancelled方法 * **/ task.cancel(true); } } }).start(); } public class MyAsyncTask extends AsyncTask { /** * 在主线程中进行初始化视图的操作 * */ @Override protected void onPreExecute() { super.onPreExecute(); Log.e("123456:", "onPreExecute is called:"); dialog = new ProgressDialog(MainActivity.this); dialog.setProgressStyle(ProgressDialog.STYLE_HORIZONTAL); dialog.setCancelable(false); dialog.show(); //准备用于保存APK文件的File对象 : /storage/sdcard/Android/package_name/files/xxx.apk apkFile = new File(getExternalFilesDir(null), "update.apk"); } /**** * 分线程中进行联网操作，下载apk * */ @Override protected String doInBackground(String... params) { try { Log.e("123456:", "doInBackground is called:"+params[0]); //1. 得到连接对象 String path = params[0]; URL url = new URL(path); HttpURLConnection connection = (HttpURLConnection) url.openConnection(); //2. 设置 //connection.setRequestMethod("GET"); connection.setConnectTimeout(5000); connection.setReadTimeout(10000); //3. 连接 connection.connect(); //4. 请求并得到响应码200 int responseCode = connection.getResponseCode(); if(responseCode==200) { //设置dialog的最大进度 dialog.setMax(connection.getContentLength()); //5. 得到包含APK文件数据的InputStream InputStream is = connection.getInputStream(); //6. 创建指向apkFile的FileOutputStream FileOutputStream fos = new FileOutputStream(apkFile); //7. 边读边写 byte[] buffer = new byte[1024]; int len = -1; while((len=is.read(buffer))!=-1) { fos.write(buffer, 0, len); //8. 显示下载进度 //dialog.incrementProgressBy(len); //在分线程中, 发布当前进度 publishProgress(len); //休息一会(模拟网速慢) //Thread.sleep(50); SystemClock.sleep(10); } fos.close(); is.close(); } //9. 下载完成, 关闭, 进入3) connection.disconnect(); } catch (Exception e) { e.printStackTrace(); Log.e("123456 doInBack exce:",e.getMessage()); return e.getMessage(); } return "apk download sucess"; } /** * 在主线程中更新进度条 * */ @Override protected void onProgressUpdate(Integer... values) { super.onProgressUpdate(values); dialog.incrementProgressBy(values[0]); } /*** * apk下载完成，在主线程中关闭进度条 * */ @Override protected void onPostExecute(String s) { super.onPostExecute(s); Log.e("123456:", "onPostExecute is called:"); dialog.dismiss(); if("apk download sucess".equalsIgnoreCase(s)){ Toast.makeText(MainActivity.this,"apk 下载成功",Toast.LENGTH_LONG).show(); installAPK(); }else { Toast.makeText(MainActivity.this,"apk下载失败"+s,Toast.LENGTH_LONG).show(); } } /** * 在主线程中执行 * 当异步任务被取消的时候调用 * * */ @Override protected void onCancelled() { super.onCancelled(); Log.e("123456:", "onCancelled is called:"); if(dialog.isShowing()){ dialog.dismiss(); } } } /** * 启动安装APK */ private void installAPK() { Intent intent = new Intent("android.intent.action.INSTALL_PACKAGE"); intent.setDataAndType(Uri.fromFile(apkFile), "application/vnd.android.package-archive"); startActivity(intent); }}
我们来看程序的打印：
07-26 17:18:50.100 7094-7094/im.weiyuan.com.myasynctask E/123456:: onPreExecute is called:
07-26 17:18:50.162 7094-7537/im.weiyuan.com.myasynctask E/123456:: doInBackground is called:http://10.12.8.8:8080/EncryptCardManager.apk07-26 17:18:57.253 7094-7132/im.weiyuan.com.myasynctask D/123456: TimeoutException07-26 17:18:57.265 7094-7537/im.weiyuan.com.myasynctask E/123456 doInBack exce:: thread interrupted07-26 17:18:57.266 7094-7094/im.weiyuan.com.myasynctask E/123456:: onCancelled is called:点击界面开始下载apk，首先在主线程中执行onPreExecute 函数，为了避免主线程被阻塞，我们开启了一个线程执行asyntask的get方法，设置的时间是10秒
然后在子线程中开始执行doInBackground 下载apk，当下载apk的任务超过10秒后，get方法抛出一个TimeoutException异常，我们此时调用asyntask的cancle方法取消doInBackground 的任务，doInBackground 的正在执行的任务被取消，抛出异常thread interrupted
当异步任务被取消的时候 onCancelled方法被调用打印onCancelled is called，这个时候
onPostExecute方法是不会被调用的。 相当的经典。