Android中的异步处理技术之AsyncTask
目录 定义和作用 AsyncTask是在Executor框架的基础上进行的封装,它实现将耗时任务移动到工作线程中进行,同时提供了方便的接口实现了工作线程和主线程的通信。 AsyncTask主要的方法 使用AsyncTask一般会用到如下方法 private static class MyTask extends AsyncTask<String,Integer,String>{ @Override protected void onPreExecute() { super.onPreExecute(); } @Override protected void onPostExecute(String s) { super.onPostExecute(s); } @Override protected void onProgressUpdate(Integer... values) { super.onProgressUpdate(values); } @Override protected void onCancelled(String s) { super.onCancelled(s); } @Override protected String doInBackground(String... strings) { return null; } } onPreExecute() 系统自动调用,一般用于UI的初始化 onPostExecute(Params params) 系统自动调用,用于任务执行完毕后的操作 onProgressUpdate(Progress... progress) 系统自动调用,一般用于更新进度条 onCancelled(Result result) 系统自动调用,任务取消时调用此方法,同时onPostExecute方法将不会被调用了 doInBackground(Result... result) 系统自动调用,用于执行后台操作 excute(Params... params) 需要手动调用,调用后将开始任务 publishProgress(count) 需要手动调用,此方法在类的内部实现,一般用于更新进度条的数据 AsyncTask的使用方法 继承AsyncTask并实现其核心方法然后手动调用excute()方法。 public class MainActivity extends AppCompatActivity { private Button btStart; private ProgressBar pb; private TextView tvState; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); btStart = (Button) findViewById(R.id.bt_start); pb = (ProgressBar) findViewById(R.id.pb); tvState = (TextView) findViewById(R.id.tv_state); final MyTask myTask=new MyTask(pb,tvState); btStart.setOnClickListener(new View.OnClickListener() { @Override public void onClick(View v) { myTask.execute(); } }); } private static class MyTask extends AsyncTask<String,Integer,String>{ @SuppressLint("StaticFieldLeak") private TextView textView; @SuppressLint("StaticFieldLeak") private ProgressBar progressBar; public MyTask(ProgressBar progressBar,TextView textView) { this.progressBar=progressBar; this.textView=textView; } @Override protected void onPreExecute() { textView.setText("开始加载"); } @Override protected void onPostExecute(String s) { textView.setText("加载完毕"); } @Override protected void onProgressUpdate(Integer... values) { progressBar.setProgress(values[0]); } @Override protected void onCancelled(String s) { textView.setText("已取消"); } @Override protected String doInBackground(String... strings) { int count=0; try { while (count<=100){ count+=1; Thread.sleep(50); publishProgress(count); } } catch (InterruptedException e) { e.printStackTrace(); } return ""; } } } xml布局 <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:orientation="vertical" android:layout_height="match_parent" tools:context=".MainActivity"> <Button android:layout_width="wrap_content" android:text="开始" android:id="@+id/bt_start" android:layout_gravity="center" android:layout_height="wrap_content" /> <ProgressBar android:layout_width="match_parent" android:layout_marginTop="20dp" android:max="100" android:id="@+id/pb" style="@style/Widget.AppCompat.ProgressBar.Horizontal" android:layout_height="wrap_content" /> <TextView android:layout_width="wrap_content" android:layout_marginTop="20dp" android:text="状态" android:id="@+id/tv_state" android:layout_gravity="center" android:layout_height="wrap_content" /> </LinearLayout> 注意 AsyncTask必须在UI线程中启动 同一个AsyncTask实例对象只能执行1次,若执行第2次将会抛出异常 AsyncTask最好声明为静态内部类 在不同版本的Android系统的 AsyncTask的execute和executeOnExecutor方法的运行有些许差别 可以看到,如果想要AsyncTask并行执行任务的话,那么在API大于13的版本中建议使用executeOnExecutor代替execute。另外如果 AsyncTask是异步执行,最多也只能有四个任务可以同时进行,其他任务需要在队列中排队,等待空闲线程。之所以会出现这种情况是由于AsyncTask的源码决定的。 public abstract class AsyncTask<Params, Progress, Result> { private static final String LOG_TAG = "AsyncTask"; private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors(); // We want at least 2 threads and at most 4 threads in the core pool, // preferring to have 1 less than the CPU count to avoid saturating // the CPU with background work private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT - 1, 4)); private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1; private static final int KEEP_ALIVE_SECONDS = 30; private static final ThreadFactory sThreadFactory = new ThreadFactory() { private final AtomicInteger mCount = new AtomicInteger(1); public Thread newThread(Runnable r) { return new Thread(r, "AsyncTask #" + mCount.getAndIncrement()); } }; ... 个人技术博客:https://myml666.github.io/