Android线程,线程池使用及原理博文参考
AllanHarnes
8年前
<p>通过以下文章的阅读，相信你对android的线程,线程池以及原理会有更加深刻的理解</p> <p>这块的知识可以说是一大块,要撸清楚还是要花点时间,线程池中关联到的队列不仅在线程池中使用,在各种第三方网络框架和图片框架等等中也是通过自己调度队列来实现异步。有关理论的东西"前人"写的好文章太多了,所以也没必要再去复制粘贴来写一篇博文（<strong>文章结尾链接一个有关线程和线程池的面试题</strong>）</p> <p>还是先回顾下Handler消息机制的原理图</p> <p><img alt="Android线程,线程池使用及原理博文参考" src="https://simg.open-open.com/show/dec8f920e57ec07c1bfa03e655ac4ee8.png"></p> <h2>Handler消息机制</h2> <p>同样的还是先看看一篇对《Android开发艺术探索》的总结，对线程和线程池有个大致的了解（建议和源码一起看）<br> <a href="http://www.open-open.com/lib/view/open1467591851626.html">Android开发艺术探索 第11章 线程与线程池 读书笔记</a></p> <p>上面的文章讲的只是基本概念，还是要看看稍微详细的文章<br> <a href="http://www.open-open.com/lib/view/open1460363173924.html">线程、多线程与线程池总结</a></p> <p>在AsyncTask源码中有使用到Callable、Future和FutureTask，对这个概念不清楚的不妨看看这篇博客<br> <a href="http://www.open-open.com/lib/view/open1453629629401.html">Java并发编程：Callable、Future和FutureTask</a></p> <p>针对书中讲到的AsyncTask附上一张AsyncTask工作原理图(结合源代码理解)</p> <p><img alt="" src="https://simg.open-open.com/show/c229e25ca76354a0bdbc16fa1b554e4c.png"></p> <p>AsyncTask工作原理</p> <p>不过不建议使用AsyncTask，因为4.x系统中AsyncTask是串行的，高并发的Task让AsyncTask一个一个串行执行，程序就会很慢。可以看看这篇译文讲解具体原因</p> <p><a href="http://www.open-open.com/lib/view/open1417955629527.html">译文：Android中糟糕的AsyncTask</a></p> <p>但是这不是我们不看源码的理由，虽然很多缺点但是掌握AsyncTask原理可以对消息机制以及线程池理解更加深刻。</p> <p>在《Android开发艺术探索》书中有提到HandlerThread和IntentService，具体的分析，可以看看<strong>洋神</strong>写的两篇文章（如果对消息机制不熟悉的建议再看看消息机制的原理，这样会更好理解这两篇文章）<br> <a href="http://www.open-open.com/lib/view/open1452953203401.html">Android HandlerThread 完全解析</a><br> <a href="/misc/goto?guid=4959674970698946876">Android IntentService完全解析 当Service遇到Handler</a></p> <p>上面的文章都没有对线程池详细的讲解,所以推荐两篇篇好文，主要是讲android中自带的5个线程池的使用以及自定义线程池的使用,例子也是根据官方的例子来讲解的,<strong>非常详细</strong><br> <a href="/misc/goto?guid=4959674970794122275">Android性能优化之使用线程池处理异步任务</a></p> <p><a href="/misc/goto?guid=4959633322035524649">【Java并发编程】之十九并发新特性—Executor框架与线程池</a></p> <p>文章提及到了默认的一个拒绝策略(AbortPolicy),这里就撸一下4种策略,使用的话只要简单传参<br> <code>new ThreadPoolExecutor.DiscardPolicy()</code></p> <p>RejectedExecutionHandler的四种拒绝策略</p> <ul> <li> <p><strong>ThreadPoolExecutor.AbortPolicy(默认策略)</strong>:<br> 当线程池中的数量等于最大线程数时抛出java.util.concurrent.RejectedExecutionException异常.<br> 涉及到该异常的任务也不会被执行.</p> </li> <li> <p><strong>ThreadPoolExecutor.CallerRunsPolicy()</strong>:<br> 当线程池中的数量等于最大线程数时,重试添加当前的任务;它会自动重复调用execute()方法</p> </li> <li> <p><strong>ThreadPoolExecutor.DiscardOldestPolicy()</strong>:<br> 当线程池中的数量等于最大线程数时,抛弃线程池中工作队列头部的任务(即等待时间最久Oldest的任务),并执行新传入的任务</p> </li> <li> <p><strong>ThreadPoolExecutor.DiscardPolicy()</strong>:<br> 当线程池中的数量等于最大线程数时,丢弃不能执行的新加任务</p> </li> </ul> <p><strong>顺便再撸一下线程池中的排队策略</strong><br> 参考自<a href="/misc/goto?guid=4959633322035524649">http://blog.csdn.net/ns_code/article/details/17465497</a><br> 排队有三种通用策略：</p> <p>1.直接提交。工作队列的默认选项是 SynchronousQueue，它将任务直接提交给线程而不保持它们。在此，如果不存在可用于立即运行任务的线程，则试图把任务加入队列将失败，因此会构造一个新的线程。此策略可以避免在处理可能具有内部依赖性的请求集合时出现锁定。直接提交通常要求无界 maximumPoolSizes 以避免拒绝新提交的任务。当命令以超过队列所能处理的平均数连续到达时，此策略允许无界线程具有增长的可能性。</p> <p>2.无界队列。使用无界队列（例如，不具有预定义容量的 LinkedBlockingQueue）将导致在所有 corePoolSize 线程都忙的情况下将新任务加入队列。这样，创建的线程就不会超过 corePoolSize。（因此，maximumPoolSize 的值也就无效了。）当每个任务完全独立于其他任务，即任务执行互不影响时，适合于使用无界队列；例如，在 Web页服务器中。这种排队可用于处理瞬态突发请求，当命令以超过队列所能处理的平均数连续到达时，此策略允许无界线程具有增长的可能性。</p> <p>3.有界队列。当使用有限的 maximumPoolSizes 时，有界队列（如 ArrayBlockingQueue）有助于防止资源耗尽，但是可能较难调整和控制。队列大小和最大池大小可能需要相互折衷：使用大型队列和小型池可以最大限度地降低 CPU 使用率、操作系统资源和上下文切换开销，但是可能导致人工降低吞吐量。如果任务频繁阻塞（例如，如果它们是 I/O 边界），则系统可能为超过您许可的更多线程安排时间。使用小型队列通常要求较大的池大小，CPU 使用率较高，但是可能遇到不可接受的调度开销，这样也会降低吞吐量。</p> <p><strong>针对几篇文章中提到的队列,这里简单总结下</strong>:<br> Queue接口与List、Set同一级别，都是继承了Collection接口。android中大量使用的BlockingQueue继承了Queue接口,线程池中的队列都是实现BlockingQueue接口,看看BlockingQueue中定义的一些接口方法</p> <table> <thead> <tr> <th>name</th> <th>note</th> <th>detail</th> </tr> </thead> <tbody> <tr> <td>add</td> <td>增加一个元素</td> <td>如果队列已满，则抛出一个IIIegaISlabEepeplian异常</td> </tr> <tr> <td>remove</td> <td>移除并返回队列头部的元素</td> <td>如果队列为空，则抛出一个NoSuchElementException异常</td> </tr> <tr> <td>element</td> <td>返回队列头部的元素</td> <td>如果队列为空，则抛出一个NoSuchElementException异常</td> </tr> <tr> <td>offer</td> <td>添加一个元素并返回true</td> <td>如果队列已满，则返回false</td> </tr> <tr> <td>poll</td> <td>移除并返问队列头部的元素</td> <td>如果队列为空，则返回null</td> </tr> <tr> <td>peek</td> <td>返回队列头部的元素</td> <td>如果队列为空，则返回null</td> </tr> <tr> <td>put</td> <td>添加一个元素</td> <td>如果队列满，则阻塞</td> </tr> <tr> <td>take</td> <td>移除并返回队列头部的元素</td> <td>如果队列为空，则阻塞</td> </tr> </tbody> </table> <p><strong>LinkedBlockingQueue</strong>默认情况下，LinkedBlockingQueue的容量是没有上限的（说的不准确，在不指定时容量为Integer.MAX_VALUE，不要然的话在put时怎么会受阻呢），但是也可以选择指定其最大容量，它是基于链表的队列，此队列按 FIFO（先进先出）排序元素。</p> <p><strong>ArrayBlockingQueue</strong>在构造时需要指定容量， 并可以选择是否需要公平性，如果公平参数被设置true，等待时间最长的线程会优先得到处理（其实就是通过将ReentrantLock设置为true来 达到这种公平性的：即等待时间最长的线程会先操作）。通常，公平性会使你在性能上付出代价，只有在的确非常需要的时候再使用它。它是基于数组的阻塞循环队 列，此队列按 FIFO（先进先出）原则对元素进行排序。</p> <p><strong>PriorityBlockingQueue</strong>是一个带优先级的 队列，而不是先进先出队列。元素按优先级顺序被移除，该队列也没有上限（看了一下源码，PriorityBlockingQueue是对 PriorityQueue的再次包装，是基于堆数据结构的，而PriorityQueue是没有容量限制的，与ArrayList一样，所以在优先阻塞 队列上put时是不会受阻的。虽然此队列逻辑上是无界的，但是由于资源被耗尽，所以试图执行添加操作可能会导致 OutOfMemoryError），但是如果队列为空，那么取元素的操作take就会阻塞，所以它的检索操作take是受阻的。另外，往入该队列中的元 素要具有比较能力。</p> <p><strong>DelayQueue</strong>（基于PriorityQueue来实现的）是一个存放Delayed 元素的无界阻塞队列，只有在延迟期满时才能从中提取元素。该队列的头部是延迟期满后保存时间最长的 Delayed 元素。如果延迟都还没有期满，则队列没有头部，并且poll将返回null。当一个元素的 getDelay(TimeUnit.NANOSECONDS) 方法返回一个小于或等于零的值时，则出现期满，poll就以移除这个元素了。此队列不允许使用 null 元素。</p> <p>参考自<a href="/misc/goto?guid=4959674970933289953">http://blog.sina.com.cn/s/blog_9815359e0102vbet.html</a></p> <p><strong>关于队列的具体解释和具体使用,这里分享一个国外的网站(英文比较基础,大部分能看懂)</strong><br> <a href="/misc/goto?guid=4959674971017130473">http://tutorials.jenkov.com/java-util-concurrent/blockingqueue.html</a></p> <p>OK,至此你已经看完了有关线程和线程池的概念以及使用,你会发现上面的文章有很多重复的地方,没错,那就是重要的地方。当然这是不够的,这里推荐两篇博文,去看看Executor线程池这个东西到底是怎么运作的</p> <p><a href="http://www.open-open.com/lib/view/open1433398104572.html">戏（细）说Executor框架线程池任务执行全过程（上）</a></p> <p><a href="/misc/goto?guid=4958877192342287792">戏（细）说Executor框架线程池任务执行全过程（下）</a></p> <h3>面试题链接</h3> <p><a href="/misc/goto?guid=4959674971142472924">JAVA多线程和并发基础面试问答</a></p> <p>Note</p> <p>当时看《Androd开发艺术探索》里分析AsyncTask原理的时候,写了一下关于子线程不能更新UI的测试代码</p> <pre> <code class="language-java">protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); textView = (TextView) findViewById(R.id.text); new Thread(new Runnable() { @Override public void run() { LogUtils.d(String.valueOf(Thread.currentThread().getId())); textView.setText("2222"); } }).start(); }</code></pre> <p>发现没报错，不正常！</p> <p>之后听了QQ群里朋友的解答去查阅了有关ViewRootImpl的原理，得出下面结论：</p> <p>首先View更新的流程为：</p> <ul> <li>View.invalidate</li> <li>View.invalidateInternal</li> <li>ViewGroup.invalidateChild</li> <li>ViewParent.invalidateChildInParent</li> <li>ViewRootImpl.invalidateChildInParent</li> <li>ViewRootImpl.checkThread</li> </ul> <pre> <code class="language-java">public final void invalidateChild(View child, final Rect dirty) { ViewParent parent = this; final AttachInfo attachInfo = mAttachInfo; if (attachInfo != null) { ...... parent = parent.invalidateChildInParent(location, dirty); ...... } }</code></pre> <p>ViewGroup.invalidateChild方法中mAttachInfo为不空时，才会继续调用ViewParent.invalidateChildInParent 。如果为空，下面的流程就不再执行，checkThread 方法也就不会执行，也就不会报错。</p> <p>view树的初始化会在ViewRootImpl的performTraversals开始执行，从DecorView开始遍历绘制view，同时也在将mAttachInfo赋值，但是onCreate完成时，Activity并没有完成初始化view树，所以上面那个情况下mAttachInfo为空。换句话说就是checkThread 的代码执行的比你更新UI的代码要晚.（上面测试代码加个click或者sleep就会报错了）</p> <h2>End</h2> <p><a href="/misc/goto?guid=4959674971226356328" style="font-size: 13px; line-height: 1.6;">阅读原文</a></p> <p> </p>