Android AsyncTask内部线程池异步执行任务机制简要分析

如下分析针对的API 25的AsyncTask的源码:

  使用AsyncTask如果是调用execute方法则是同步执行任务,想要异步执行任务可以直接调用executeOnExecutor方法,多数情况下我们会使用AsyncTask内部静态的线程池,

THREAD_POOL_EXECUTOR,这里并不是要分析AsyncTask内部的流程,而是简单介绍下线程池的工作流程。可以看到THREAD_POOL_EXECUTOR的配置如下:

new ThreadPoolExecutor( CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_SECONDS, TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory);

简单介绍下ThreadPoolExecutor的几个参数:

  int corePoolSize,核心线程数,可以一直存活在线程池中,除非设置了allowCoreThreadTimeOut,即允许核心线程超时。 int maximumPoolSize, 线程池中允许的最大线程数。long keepAliveTime,  当线程池中的线程数超过核心线程数时,非核心线程在等待keepAliveTime时间终止,即非核心线程空等待任务(存活时间)的超时时间是keepAliveTime,TimeUnit unit, 超时时间的单位,BlockingQueue<Runnable> workQueue, 缓冲任务队列,ThreadFactory threadFactory 用于创建新线程,可以设置线程优先级等。具体可以查看API文档或java.util.concurrent.ThreadPoolExecutor的源码

具体来说,当一个任务被提交到线程池后,会先看核心线程是否都有任务正在执行,如果核心线程有空闲,则核心线程执行任务,否则将任务添加到缓冲队列中,待核心线程执行完任务后取缓冲队列中的任务执行。如果任务较多,缓冲队列添加满了,且还有任务提交,那么会启动非核心线程执行任务,如果非核心线程数也全部都在工作,即线程池中的线程数达到了最大线程数 MAXIMUM_POOL_SIZE的限制时,再提交任务到线程池则会报拒绝执行任务的异常 java.util.concurrent.RejectedExecutionException

  可以用如下代码简单测试下:

  先自定义一个AsyncTask

  

static int index = 1;static class MyAsyncTask extends AsyncTask<Void, Void, Void> {
        @Override
        protected Void doInBackground(Void... params) {
            SystemClock.sleep(2000);
            return null;
        }

        @Override
        protected void onPostExecute(Void aVoid) {
            Log.d(this.getClass().getSimpleName(), "task#" + index  + " had executed.");
            index++;
        }
    }

  这里为了能够看到如上表述的过程,在doInbackground中让线程睡眠2秒,并对每个AsyncTask输出执行完成的log,附带index标识是第几个。

  然后提交任务到线程池中

        int CPU_COUNT = Runtime.getRuntime().availableProcessors();
        int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT - 1, 4));
        int MAXIMUM_POOL_SIZE = CPU_COUNT * 2 + 1;

        int taskMaxCounts =  MAXIMUM_POOL_SIZE + 128;
        for (int i = 0 ; i < taskMaxCounts; i++ ) {
            new MyAsyncTask().executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR, (Void)null);
        }

  最大可同时容纳的任务数即: MAXIMUM_POOL_SIZE + 128 (缓冲队列任务数), 针对API25的版本, 如何CPU是4核心,那么最大任务数是 4 * 2 + 1 + 128 = 137 .

  当线程池中线程都有任务正在执行且缓冲队列已满时,继续往线程池中提交任务则会报异常,这里可以将taskMaxCounts 改为 MAXIMUM_POOL_SIZE + 129,

  再次运行程序则会看到异常log信息

  

 FATAL EXCEPTION: main
   Process: com.aquarius.test, PID: 22425
   java.lang.RuntimeException: Unable to start activity ComponentInfo{com.aquarius.test/com.http.study.demo.VolleyActivity}: java.util.concurrent.RejectedExecutionException: Task [email protected] rejected from [email protected][Running, pool size = 9, active threads = 9, queued tasks = 128, completed tasks = 0]
   at android.app.ActivityThread.performLaunchActivity(ActivityThread.java:2449)
   at android.app.ActivityThread.handleLaunchActivity(ActivityThread.java:2509)
   at android.app.ActivityThread.access$1000(ActivityThread.java:153)
   at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1373)
   at android.os.Handler.dispatchMessage(Handler.java:102)
   at android.os.Looper.loop(Looper.java:154)
   at android.app.ActivityThread.main(ActivityThread.java:5524)
   at java.lang.reflect.Method.invoke(Native Method)
   at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:740)
   at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:630)
   Caused by: java.util.concurrent.RejectedExecutionException: Task [email protected] rejected from [email protected][Running, pool size = 9, active threads = 9, queued tasks = 128, completed tasks = 0]
              at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2014)
              at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:794)
              at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1340)
              at android.os.AsyncTask.executeOnExecutor(AsyncTask.java:607)

  

时间: 2024-10-07 16:25:04

Android AsyncTask内部线程池异步执行任务机制简要分析的相关文章

使用Android新式LruCache缓存图片,基于线程池异步加载图片

import java.io.BufferedInputStream; import java.io.ByteArrayOutputStream; import java.io.InputStream; import java.net.HttpURLConnection; import java.net.URL; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import a

Android开发之线程池使用总结

线程池算是Android开发中非常常用的一个东西了,只要涉及到线程的地方,大多数情况下都会涉及到线程池.Android开发中线程池的使用和Java中线程池的使用基本一致.那么今天我想来总结一下Android开发中线程池的使用. OK,假如说我想做一个新闻应用,ListView上有一个item,每个item上都有一张图片需要从网络上加载,如果不使用线程池,你可能通过下面的方式来开启一个新线程: new Thread(new Runnable() { @Override public void ru

AsyncTask中线程池调度分析

尊重原创:http://blog.csdn.net/yuanzeyao/article/details/42583215 在Android中,和异步执行相关的两个类就是Handler和AsyncTask,所以Android开发人员对于这两个类是再熟悉不过了,所以这里我不是讲解AsyncTask怎么使用,而是想分析一下AsyncTask中线程池的调度过程,然后简单的介绍一下AsyncTask的源码以及Android3.0前后,AsyncTask中线程池的区别. 在正式学习AsyncTask中的线程

Android下基于线程池的网络访问基础框架

引言 现在的Android开发很多都使用Volley.OkHttp.Retrofit等框架,这些框架固然有优秀的地方(以后会写代码学习分享),但是我们今天介绍一种基于Java线程池的网络访问框架. 实现思路及实现 APP界面上面的数据都是通过网络请求获取的,我们能不能将网络请求依次入队,然后配合着Java线程池,让线程依次处理我们的请求,最后返回结果给我们.下面我们先来看一下线程池工具类的实现: 1 public class ThreadPoolUtils { 2 3 private Threa

带你一步步实现线程池异步回调

转载请注明出处 作者:晓渡文章地址:https://greatestrabit.github.io/2016/03/29/callback/ 1.字面意义上的回调 字面意思上理解回调,就是A调用B,B回过头来再调用A,即是回调.既然是这样,当然就要求A中有B,B中有A.如下: class A { /**  * 提出问题  * @author [email protected]  * @param b  * @param question  */ public void ask(final B b

线程池的执行流程

合理使用线程池能够带来3个好处: 1)降低资源消耗:2)提高响应速度:3)提高线程的可管理性. 那么线程池是如何工作的呢,借用并发编程艺术一书中的话来描述当一个任务提交给线程池之后,线程池会怎么做? 首先,线程池会判断核心线程池里的线程(线程总数是30,则coreSize有可能是10)是否都在执行任务.如果没有比方说当前只有9个线程在工作,则从核心线程池中创建一个新的线程来执行任务.如果当前已经有10个线程在工作了,则进入下一步: 其次,线程池会判断工作队列是否已经满了,如果工作队列没有满,则将

戏(细)说Executor框架线程池任务执行全过程(上)

一.前言 1.5后引入的Executor框架的最大优点是把任务的提交和执行解耦.要执行任务的人只需把Task描述清楚,然后提交即可.这个Task是怎么被执行的,被谁执行的,什么时候执行的,提交的人就不用关心了.具体点讲,提交一个Callable对象给ExecutorService(如最常用的线程池ThreadPoolExecutor),将得到一个Future对象,调用Future对象的get方法等待执行结果就好了. 经过这样的封装,对于使用者来说,提交任务获取结果的过程大大简化,调用者直接从提交

Android -- Vold机制简要分析

Android -- Vold机制简要分析 Vold是用于管理和控制Android外部存储介质的后台进程,这里说的管控,主要包括SDK的插拔.挂载/卸载和格式化等:它是Android平台外部存储系统的管控枢纽. Vold的整个控制模块主要由三个类模块构成:NetlinkManager.VolumeManager和CommandListener,它们的功能划分大概是: NetlinkManager:用于从kernel中获取SD卡插拔的Uevnet消息 VolumeManager:管理模块,对Net

Android 开发 ThreadPool(线程池) 总结

本文是介绍线程池的基础篇. 首先介绍一个方法,获取CPU个数: int cpuCount = Runtime.getRuntime().availableProcessors(); 一.创建异步线程的弊端. 1.每次new Thread创建对象,导致性能变差. 2.缺乏统一的管理,可能导致无限制的线程运行,严重的后果就是OOM 或者死机. 二.启用线程池的优点. 1.重用性大,减少对象的创建,提高性能. 2.可有效控制并发线程数,提高系统资源利用率,避免资源争夺. 3.可提供多种功能:定时.循环