参考:http://www.jianshu.com/p/6637369d02e7
1. 线程池基础
1.1. 线程池好处
初学Android时异步都用new Thread+Handler,但是java还有个利器,线程池。比如Picasso、Rxjava等框架使用的都是线程池。
线程池的关键在于线程复用以减少非核心任务的损耗。主要原因在于减少了创建线程、销毁线程的时间。
1.2. OkHttp中的线程池
首先,OkHttp拥有2种运行方式,一种是同步阻塞调用并直接返回的形式,另一种是通过内部线程池分发调度实现非阻塞的异步回调。这两讲的是第二种方式。
OkHttp配置的的线程池在Dispatcher类里:
public synchronized ExecutorService executorService() {
if (executorService == null) {
executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS,
new SynchronousQueue<Runnable>(), Util.threadFactory("OkHttp Dispatcher", false));
}
return executorService;
}
new了一个核心线程(或最小保留线程)为0、最大线程数为Integer.MAX_VALUE、空闲线程存活时间为60s的线程池。但是Dispatcher默认同时支持最多64个并发请求,单个IP最多5个请求(可以设定)。
1.3. OkHttp任务调度
在OkHttp的异步请求时,一般进行如下构造
OkHttpClient client = new OkHttpClient.Builder().build();
Request request = new Request.Builder()
.url("http://qq.com").get().build();
client.newCall(request).enqueue(new Callback() {
@Override
public void onFailure(Call call, IOException e) { }
@Override
public void onResponse(Call call, Response response) throws IOException { }
}
);
但是最终enqueue执行的是Dispatcher的入队操作:
synchronized void enqueue(AsyncCall call) {
if (runningAsyncCalls.size() < maxRequests && runningCallsForHost(call) < maxRequestsPerHost) {
//添加正在运行的请求
runningAsyncCalls.add(call);
//线程池执行请求
executorService().execute(call);
} else {
//添加到缓存队列排队等待
readyAsyncCalls.add(call);
}
}
这里的maxRequests 就是默认最大并发64,maxRequestsPerHost则为每个ip最大并发数。
1.4. AsyncCall
从上面的代码可以看到Dispatcher的enqueue方法中需要的是AsyncCall。参考原文可以知道finally中执行了这行代码:
client.dispatcher().finished(this);
这行代码有两个作用,1、完成本次执行的任务。2、调用下个任务的执行。这是OkHttp一个很出彩的地方,就是在try/finally中调用了finished函数,可以主动控制等待队列的移动,而不是采用锁,极大减少了编码复杂性。
------总结-----
1、在多线程任务调度中可以用类似反向代理(如似于Nginx)与线程池配合实现了高并发,低阻塞的运行
2、在AsyncCall 中采用try/finally中调用了finished函数,主动控制等待队列的移动,而不是采用锁
3、采用Deque作为缓存,按照入队的顺序先进先出