Android:AsyncTask源码解读

标题党

AsyncTask源码解读,解读这么流弊的标题,吓得我都不敢写下去啦!菜鸟一枚,写不对的地方,请各位大神在留下评论或拍砖,我会为大家贡献更多多的妹子图。


妹子镇楼

PS妹子图镇楼,可以增加阅读量

AsyncTask简单使用

  1. 直接上代码,很简单就是在子线程中结算1到100的和。妹子你走开,我要开始撸代码啦!
public static void main(String arg[]) throws InterruptedException {
        MyTask task = new MyTask();
        task.execute(100);
    }
 static class MyTask extends AsyncTask<Integer, Integer, Integer> {
        @Override
        protected void onPreExecute() {
            System.out.println("onPreExecute");
            super.onPreExecute();
        }
        @Override
        protected void onProgressUpdate(Integer... values) {
            System.out.println("onProgressUpdate " + values[0]);
            super.onProgressUpdate(values);
        }
        @Override
        protected Integer doInBackground(Integer... integers) {
            //在新的线程中执行
            int sum = 0;
            for (int i = 0; i < integers[0]; i++) {
                sum = sum + i;
                publishProgress(i);//给InternalHandler发送进度更新的消息
            }
            return sum;
        }

        @Override
        protected void onPostExecute(Integer integer) {
            //将子线程的结果post到主线程
            super.onPostExecute(integer);
        }
    }
  1. 稍微介绍重要的几个方法;暂时忘记到妹子图吧!看看以下四个方法:@MainThread表示在主线程中执行,而@WorkerThread表示在子线程中执行
@MainThread
protected void onPreExecute() 
@MainThread
protected void onPostExecute(Result result) 
@MainThread
protected void onProgressUpdate(Progress... values)
@WorkerThread
protected abstract Result doInBackground(Params... params)
  • onPreExecute:表示该方法是运行在主线程中的。在AsyncTask执行了execute()方法后就会在UI线程上执行onPreExecute()方法,该方法在task真正执行前运行,我们通常可以在该方法中显示一个进度条,从而告知用户后台任务即将开始。

  • doInBackground :表示该方法是运行在单独的工作线程中的,而不是运行在主线程中。doInBackground会在onPreExecute()方法执行完成后立即执行,该方法用于在工作线程中执行耗时任务,我们可以在该方法中编写我们需要在后台线程中运行的逻辑代码,由于是运行在工作线程中,所以该方法不会阻塞UI线程。该方法接收Params泛型参数,参数params是Params类型的不定长数组,该方法的返回值是Result泛型,由于doInBackgroud是抽象方法,我们在使用AsyncTask时必须重写该方法。在doInBackground中执行的任务可能要分解为好多步骤,每完成一步我们就可以通过调用AsyncTask的publishProgress(Progress…)将阶段性的处理结果发布出去,阶段性处理结果是Progress泛型类型。当调用了publishProgress方法后,处理结果会被传递到UI线程中,并在UI线程中回调onProgressUpdate方法,下面会详细介绍。根据我们的具体需要,我们可以在doInBackground中不调用publishProgress方法,当然也可以在该方法中多次调用publishProgress方法。doInBackgroud方法的返回值表示后台线程完成任务之后的结果。

  • onProgressUpdate 上面我们知道,当我们在doInBackground中调用publishProgress(Progress…)方法后,就会在UI线程上回调onProgressUpdate方法
    注解,表示该方法是在主线程上被调用的,且传入的参数是Progress泛型定义的不定长数组。如果在doInBackground中多次调用了publishProgress方法,那么主线程就会多次回调onProgressUpdate方法。

  • onPostExecute :表示该方法是在主线程中被调用的。当doInBackgroud方法执行完毕后,就表示任务完成了,doInBackgroud方法的返回值就会作为参数在主线程中传入到onPostExecute方法中,这样就可以在主线程中根据任务的执行结果更新UI。

内部实现

上面讲了那么多,然而都不是重点,现在才刚开始进入主题。AsyncTask其实就是用线程池和和handle实现的!

  1. AsyncTask的三个状态
public enum Status {
        /**
         * Indicates that the task has not been executed yet.
         * 还没有执行
         */
        PENDING,
        /**
         * Indicates that the task is running.
        *  正在执行
        */
        RUNNING,
        /**
         * Indicates that {@link AsyncTask#onPostExecute} has finished.
         * 执行结束
         */
        FINISHED,
    }
  1. 子线程与主线程通讯:(handle)
private static class InternalHandler extends Handler {
        public InternalHandler() {
            super(Looper.getMainLooper());
        }

        @SuppressWarnings({"unchecked", "RawUseOfParameterizedType"})
        @Override
        public void handleMessage(Message msg) {
            AsyncTaskResult<?> result = (AsyncTaskResult<?>) msg.obj;
            switch (msg.what) {
                case MESSAGE_POST_RESULT:
                    // There is only one result
                    result.mTask.finish(result.mData[0]);//调用onPostExecute 将结果post到主线程
                    break;
                case MESSAGE_POST_PROGRESS://调用onProgressUpdate更新进度 
                    result.mTask.onProgressUpdate(result.mData);
                    break;
            }
        }
    }
private void finish(Result result) {
        if (isCancelled()) {
            onCancelled(result);
        } else {
            onPostExecute(result);
        }
        mStatus = Status.FINISHED;
    }
  1. 构造函数
public AsyncTask() {
        mWorker = new WorkerRunnable<Params, Result>() {
            public Result call() throws Exception {
                mTaskInvoked.set(true);
             Process.setThreadPriority(Process.THREAD_PRIORITY_BACKGROUND);
                //noinspection unchecked
                Result result = doInBackground(mParams);//调用doInBackground 在子线程中做一系列的事情
                Binder.flushPendingCommands();
                return postResult(result);//给InternalHandler发送一个doInBackground任务执行完成的消息
            }
        };

        mFuture = new FutureTask<Result>(mWorker) {
            @Override
            protected void done() {
                try {
                    postResultIfNotInvoked(get());//等待mWorker的call方法执行完成
                } catch (InterruptedException e) {
                    android.util.Log.w(LOG_TAG, e);
                } catch (ExecutionException e) {
                    throw new RuntimeException("An error occurred while executing doInBackground()",
                            e.getCause());
                } catch (CancellationException e) {
                    postResultIfNotInvoked(null);//如果doInBackground发生异常,则向主线程发送一个null的结果
                }
            }
        };
    }
  1. execute(params)最终调用executeOnExecutor
public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,
           Params... params) {
       if (mStatus != Status.PENDING) {//判断任务的状态是不是没有执行过
           switch (mStatus) {
               case RUNNING:
                   throw new IllegalStateException("Cannot execute task: the task is already running.");
               case FINISHED:
                   throw new IllegalStateException("Cannot execute task: the task has already been executed (a task can be executed only once)");
           }
       }
       mStatus = Status.RUNNING;
       onPreExecute();//在主线程总调用onPreExecute
       mWorker.mParams = params;//mWorker 设置参数
       exec.execute(mFuture);//线程池执行futureTask
       return this;
   }
  1. AsyncTask执行一个task的流程图
流程图1
流程图2
流程图3
流程图4
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容