picasso-高级使用配置线程池

本文主要是介绍picasso-高级使用配置线程池，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

2.自定义线程池
通过上一片博客我们了解了picasso通过Build模式构建构建的代码如下

 if (service == null) {service = new PicassoExecutorService();}

想了解picasso设置缓存位置以及源码如何构建picasso的可以参考下面的博客
picasso源码构建分析及下载位置设置
那首先我们看picasso默认的线程池是什么样子的源码如下

class PicassoExecutorService extends ThreadPoolExecutor {private static final int DEFAULT_THREAD_COUNT = 3;PicassoExecutorService() {super(DEFAULT_THREAD_COUNT, DEFAULT_THREAD_COUNT, 0, TimeUnit.MILLISECONDS,new PriorityBlockingQueue<Runnable>(), new Utils.PicassoThreadFactory());}void adjustThreadCount(NetworkInfo info) {if (info == null || !info.isConnectedOrConnecting()) {setThreadCount(DEFAULT_THREAD_COUNT);return;}switch (info.getType()) {case ConnectivityManager.TYPE_WIFI:  //wificase ConnectivityManager.TYPE_WIMAX:case ConnectivityManager.TYPE_ETHERNET:setThreadCount(4);break;case ConnectivityManager.TYPE_MOBILE:switch (info.getSubtype()) {case TelephonyManager.NETWORK_TYPE_LTE:  // 4Gcase TelephonyManager.NETWORK_TYPE_HSPAP:case TelephonyManager.NETWORK_TYPE_EHRPD:setThreadCount(3);break;case TelephonyManager.NETWORK_TYPE_UMTS: // 3Gcase TelephonyManager.NETWORK_TYPE_CDMA:case TelephonyManager.NETWORK_TYPE_EVDO_0:case TelephonyManager.NETWORK_TYPE_EVDO_A:case TelephonyManager.NETWORK_TYPE_EVDO_B:setThreadCount(2);break;case TelephonyManager.NETWORK_TYPE_GPRS: // 2Gcase TelephonyManager.NETWORK_TYPE_EDGE:setThreadCount(1);break;default:setThreadCount(DEFAULT_THREAD_COUNT);}break;default:setThreadCount(DEFAULT_THREAD_COUNT);}}private void setThreadCount(int threadCount) {setCorePoolSize(threadCount);setMaximumPoolSize(threadCount);}@Overridepublic Future<?> submit(Runnable task) {PicassoFutureTask ftask = new PicassoFutureTask((BitmapHunter) task);execute(ftask);return ftask;}private static final class PicassoFutureTask extends FutureTask<BitmapHunter>implements Comparable<PicassoFutureTask> {private final BitmapHunter hunter;public PicassoFutureTask(BitmapHunter hunter) {super(hunter, null);this.hunter = hunter;}@Overridepublic int compareTo(PicassoFutureTask other) {Picasso.Priority p1 = hunter.getPriority();Picasso.Priority p2 = other.hunter.getPriority();// High-priority requests are "lesser" so they are sorted to the front.// Equal priorities are sorted by sequence number to provide FIFO ordering.return (p1 == p2 ? hunter.sequence - other.hunter.sequence : p2.ordinal() - p1.ordinal());}}
}

构造方法我们就不再做过多的分析很简单的一个调用super的方法
下面我们分析picasso强大线程池的第一个方法 adjustThreadCount(NetworkInfo info)第一个判断

if (info == null || !info.isConnectedOrConnecting()) {setThreadCount(DEFAULT_THREAD_COUNT);return;}private void setThreadCount(int threadCount) {setCorePoolSize(threadCount);setMaximumPoolSize(threadCount);}

意思是如果网络没连接的情况下picasso会默认给我们设置核心线程数跟最大线程数为默认的3。知道了这个我们下面的swich方法处理也就一目了然了 wifi情况下给我们创建了一个核心数为4的线程池，4G 3的线程池，3G 2的线程池，2G 1的线程池，由此可见picasso的线程池是根据我们的网络状态控制的。

接下来我们来看picasso的下一个方法submit(Runnable task)关键代码如下

 PicassoFutureTask ftask = new PicassoFutureTask((BitmapHunter) task);execute(ftask);

我们看到如果一个线程池执行任务是直接调用 execute(task);该方法在picasso中picasso是将runnable转换成了自己的PicassoFutureTask 来执行好我们继续看PicassoFutureTask 是如何处理我们的线程池的那就是我们PicassoExecutorService 最下面的一个内部类了对于FutureTask 的认识看如下介绍：
一个FutureTask 可以用来包装一个 Callable 或是一个runnable对象。因为FurtureTask实现了Runnable方法，所以一个 FutureTask可以提交(submit)给一个Excutor执行(excution)。
也就是说我们的FurtureTask是一个特殊的Runnable他可以判断我们的runnable是不是执行完了也可以终止我们的线程，再看我们的BitmapHunter

class BitmapHunter implements Runnable{......
}

里面的代码太多了我在这里就先不做过多介绍了从继承关系上看他是一个实现了Runnable接口的类。
compareTo(PicassoFutureTask other) 是给任务排序的方法。
最终我们总结出我们的PicassoFutureTask是一个继承特殊runnable 可以随时终止任务的，实现Comparable的内部类它的功能是
1.控制runnable的执行
2.对比Priority的优先级给runnable排序

哈哈写到这里感觉是在分析源码了好吧接下来讲解如何给picasso设置线程池代码如下

   ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(CPU_COUNT + 1, CPU_COUNT * 2 + 1,1, TimeUnit.MINUTES, new PriorityBlockingQueue<Runnable>());Picasso picasso = new Picasso.Builder(this).executor(threadPoolExecutor).build();Picasso.setSingletonInstance(picasso);//这句话很重要别忘了加上啊picasso.load("http://i2.17173cdn.com/i7mz64/YWxqaGBf/tu17173com/20151019/phiDLtbkbFqzitl.jpg").into(iv);