Android - 如何检查ThreadPoolExecutor是否已达到队列限制？

Question

我在我的应用程序中使用了许多AsyncTask类。我总是开始使用它们：

if(Build.VERSION.SDK_INT >= Build.VERSION_CODES.HONEYCOMB) { 
    asyncTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); 
} else { 
    asyncTask.execute(); 
} 

最近我得到了RejectedExecutionException异常。我了解了这一点，并理解了为什么会发生这种情况（超出了线程池执行程序可以在其队列中执行的最大任务数）。

但我没有阅读任何关于检查线程池执行程序是否有可用插槽的方法，以便我可以避免这种情况。从我测试的asyncTask.execute（）;方法没有这个限制。

所以我在寻找这样的事情：

if(executorCanHandlerAnotherQueue()){ 
    if(Build.VERSION.SDK_INT >= Build.VERSION_CODES.HONEYCOMB) { 
     asyncTask.executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR); 
    } else { 
     asyncTask.execute(); 
    } 
} 
else{ 
    asyncTask.execute(); 
} 

如何向后兼容实现这个任何想法多达API 9？

Answer 1

AsyncTask使用线程池模式，所以它只是提供一个默认的线程数。如果调用execute（），任务将等待工作线程空闲。

要以真正的并行方式执行，可以调用executeOnExecutor（）。但它也是有限的（最大任务数=线程池大小+任务队列大小）。

您可以创建自定义的Executor来增加这样的线程或任务队列的数量：

public static final Executor CUSTOM_THREAD_POOL_EXECUTOR 
     = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE, 
       TimeUnit.SECONDS, sPoolWorkQueue, sThreadFactory); 

对于运行执行人（）函数的Android比蜂窝时，您可以使用

AsyncTaskCompat.executeParallel(task, params); 

从支持v4库。

您可以在此answer

UPDATE找到更多的细节：

检查可用之前执行遗嘱执行人，你可以写一个小功能，像：

boolean canExecutorAddAnotherQueue(ThreadPoolExecutor executor){ 
     int active = executor.getActiveCount(); 
     int corePoolSize = executor.getCorePoolSize(); 
     int poolSize = executor.getPoolSize(); 
     if (active < corePoolSize || active < poolSize) return true; 
     int queueSize = executor.getQueue().size(); 
     if (queueSize < MAX_QUEUE_SIZE_YOU_DEFINED) return true; 
     return false; 
    } 

但它有可能会错过一些案件也接受。

最终的答案：

所以我找到了最好的选择是使用尝试捕捉：

 try { 
      //execute asynctask 
     } catch (RejectedExecutionException e){ 
      //Handle when has exception thrown 
     } 

或使用自定义处理程序：

public ThreadPoolExecutor(int corePoolSize, 
          int maximumPoolSize, 
          long keepAliveTime, 
          TimeUnit unit, 
          BlockingQueue<Runnable> workQueue, 
          ThreadFactory threadFactory, 
          RejectedExecutionHandler handler) 

您可以编写自己的处理程序处理任务被拒绝的情况，并且不再抛出RejectedExecutionException。