美文网首页
Handler学习(3)

Handler学习(3)

作者: 景山道人 | 来源:发表于2019-07-12 15:55 被阅读0次

    Android

    AsyncTask

    Java Doc API 27:

    AsyncTask即Asynchronous Task,异步任务。AsyncTask能更好地利用UI线程,可以运行后台操作然后在UI线程上展示结果,无需创建一堆线程或者Handler。
    AsyncTask最好用于短时间操作,不超过数秒钟。如果要长时间保持线程运行一个操作的话,最好使用java.util.concurrent包下面的API,比如Executor,ThreadPoolExecutor,FutureTask。
    主要分为三种类型,Params,Progress和Result,即传入的三种泛型。以及四个步骤,onPreExecute,doInBackground,onProgressUpdate和onPostExecute,要注意的是拿来定义泛型的需要是包装类型,比如Integer
    AsyncTask是个抽象类,所以必须继承使用(此外如果用做内部类要注意内存泄漏),必须重写doInBackground
    使用方法很简单:new MyAsyncTask().execute(.., .., ..)即可
    三种泛型:Params,用于传给任务执行的参数
    Progress,后台运算过程中打印出来的过程单位
    Result,后台运算结果
    如果哪种泛型用不上,标注为Void即可,比如
    public class MyAsyncTask extends AsyncTask<Void, Void, Void> {

    }
    四个步骤:
    onPreExecute(): 在任务被执行之前,在UI线程调用,用于设置任务,比如显示一个Progress Bar
    doInBackground(): 在onPreExecute执行完后立刻在后台线程执行,可以把参数传到这里,调用publishProgress可以把参数传到onProgressUpdate以便在UI线程执行
    onProgressUpdate(): 同上,可以以任何形式展示当前进度,比如展示进度条或者打log
    onPostExecute(): 后台计算完成后在UI线程调用,结果会作为参数(在doInBackground中以return形式)传过来
    取消任务
    调用cancel(boolean)即可,之后isCancelled()会返回true,onCancelled(Object)会被调用,可以在doInBackground里面不断检查isCancelled()的返回值
    线程使用规则:

    1. AsyncTask必须在UI线程创建
    2. 必须在UI线程加载(API16之后这事会自动完成)
    3. execute()方法必须在UI线程执行
    4. 不要主动调用里面的四个步骤方法
    5. 任务只能执行一次
      内存观测:
      这点没太看懂,应该是指onPreExecute中和构造中定义的变量,在doInBackground中指向不会受到同步的影响,同理doInBackground中设置和onPostExecute中指向也不会。
      执行顺序:
      原先默认能同时执行多个任务,现在想要执行多个任务需要传入自定义的Executor
    public abstract class AsyncTask<Params, Progress, Result> {
        ...
        private static InternalHandler sHandler;
        private final Handler mHandler;
        ...
        /**
         * Creates a new asynchronous task. This constructor must be invoked on the UI thread.
         */
        public AsyncTask() {
            this((Looper) null);
        }
    
        /**
         * @hide
         */
        public AsyncTask(@Nullable Handler handler) {
             this(handler != null ? handler.getLooper() : null);
        }
    
         /**
          * @hide
          */
        public AsyncTask(@Nullable Looper callbackLooper) {
            mHandler = callbackLooper == null || callbackLooper == Looper.getMainLooper()
                ? getMainHandler()
                : new Handler(callbackLooper);
            ...
        }
    }
    

    从这里就能看出来,它是只能继承使用的,而三个定义在这里的泛型名称分别是用于三个步骤方法的。
    而两个Handler,mHandler和sHandler其实都是同一个,因为第二个构造方法被标注为hide了,要使用Looper就只能为空,所以注释里一直在强调一定运行在UI线程中,不在UI线程的话,先不说Handler创建时可能抛Exception,最后处理消息时也发不回UI线程来。

    关于InternalHandler

    private void finish(Result result) {
        if (isCancelled()) {
            onCancelled(result);
        } else {
            onPostExecute(result);
        }
        mStatus = Status.FINISHED;
    }
    
    private static class InternalHandler extends Handler {
        public InternalHandler(Looper looper) {
            super(looper);
        }
    
        @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]);
                    break;
                case MESSAGE_POST_PROGRESS:
                    result.mTask.onProgressUpdate(result.mData);
                    break;
            }
        }
    }
    

    消息类型两种,Result和Progress,可以看出来onProgressUpdate, onPostExecute和onCancelled都是从这里收到消息,在主线程处理的。
    发消息的地方:

    private Result postResult(Result result) {
        @SuppressWarnings("unchecked")
        Message message = getHandler().obtainMessage(MESSAGE_POST_RESULT,
                new AsyncTaskResult<Result>(this, result));
        message.sendToTarget();
        return result;
    }
    
    @WorkerThread
    protected final void publishProgress(Progress... values) {
        if (!isCancelled()) {
            getHandler().obtainMessage(MESSAGE_POST_PROGRESS,
                    new AsyncTaskResult<Progress>(this, values)).sendToTarget();
        }
    }
    

    其中,publishProgress是主动调用的,postResult则在WorkerRunnable和FutureTask中

    mWorker = new WorkerRunnable<Params, Result>() {
        public Result call() throws Exception {
            Result result = null;
            try {
                result = doInBackground(mParams);
            } finally {
                postResult(result);
            }
            return result;
        }
    };
    
    mFuture = new FutureTask<Result>(mWorker) {
        @Override
        protected void done() {
            try {
                postResultIfNotInvoked(get());
            } catch (CancellationException e) {
                postResultIfNotInvoked(null);
            }
        }
    };
    

    里面多余的代码被去掉了,执行时也就是

    @MainThread
    public final AsyncTask<Params, Progress, Result> executeOnExecutor(Executor exec,
            Params... params) {
        if (mStatus != Status.PENDING) {
            switch (mStatus) {
                case RUNNING:
                    throw new IllegalStateException("...");
                case FINISHED:
                    throw new IllegalStateException("...");
            }
        }
    
        mStatus = Status.RUNNING;
    
        onPreExecute();
    
        mWorker.mParams = params;
        exec.execute(mFuture);
    
        return this;
    }
    

    在正式执行futureTask之前,onPreExecute会被调用,而刚开始会判断状态,代表这个task不能再运行第二次。
    尝试写一个AsyncTask

    
    public class AsyncTaskTest extends AsyncTask<List, Integer, Integer> {
    
        private final static String TAG_ASYNC_TASK = "tag_async_task";
    
        @Override
        protected Integer doInBackground(List... lists) {
            if (null == lists || lists.length == 0) {
                return 0;
            }
            ArrayList<List> testLists = new ArrayList<>();
            for (List testList : lists) {
                for (int i = 0; i < (int) (Math.random() * 100); i++) {
                    testList.add(i);
                }
                testLists.add(testList);
            }
            int sortedCount = 0;
            for (List currList : testLists) {
                Collections.sort(currList);
                publishProgress(sortedCount);
                sortedCount++;
            }
            return sortedCount;
        }
    
        @Override
        protected void onProgressUpdate(Integer... values) {
            Log.d(TAG_ASYNC_TASK, values[0] + "");
        }
    
        @Override
        protected void onPostExecute(Integer integer) {
            Log.d(TAG_ASYNC_TASK, integer + "");
        }
    }
    
    
    

    相关文章

      网友评论

          本文标题:Handler学习(3)

          本文链接:https://www.haomeiwen.com/subject/izqykctx.html