剖析 Android 开源框架——深度解析 OkHttp 框架任务核心类 Dispatcher（完结篇）

2023-09-28 07:53:39

任务队列管理

Dispatcher 内部维护了一个任务队列，用于存储等待执行的任务。这个队列是一个双端队列，既可以从队头插入任务，也可以从队尾插入任务。当有新的任务需要执行时，Dispatcher 会将任务添加到队尾。当有空闲的线程可以执行任务时，Dispatcher 会从队头取出任务并将其分配给线程执行。

任务队列的长度是有限的，默认情况下为 64。当任务队列已满时，Dispatcher 会拒绝新的任务，并抛出 IllegalStateException 异常。您可以通过设置 dispatcher.setMaxRequestsPerHost() 方法来调整任务队列的长度。

任务分发策略

Dispatcher 使用轮询策略来分发任务。这意味着 Dispatcher 会将任务平均分配给所有可用的线程。这种策略可以确保每个线程都有机会执行任务，从而提高任务执行的效率。

如果您希望某些任务具有更高的优先级，可以调用 request.setPriority() 方法来设置任务的优先级。优先级较高的任务将被优先执行。

任务执行流程

当 Dispatcher 将任务分配给线程后，线程会执行任务。任务执行的流程如下：

线程从任务队列中取出任务。
线程调用任务的 run() 方法。
任务的 run() 方法执行任务的逻辑。
任务的 run() 方法返回结果。
线程将结果返回给 Dispatcher。
Dispatcher 将结果传递给任务的回调函数。

任务取消

您可以通过调用 request.cancel() 方法来取消任务。当任务被取消后，Dispatcher 会将其从任务队列中移除，并且任务不会被执行。

任务重试

如果任务执行失败，Dispatcher 会根据重试策略对任务进行重试。默认情况下，Dispatcher 会对任务进行 3 次重试。您可以通过设置 dispatcher.setRetryPolicy() 方法来调整重试策略。

任务超时

如果任务在指定的时间内没有执行完成，Dispatcher 会将任务标记为超时。默认情况下，任务的超时时间为 10 秒。您可以通过设置 dispatcher.setTimeout() 方法来调整任务的超时时间。

任务跟踪

Dispatcher 可以跟踪任务的执行状态。您可以通过调用 dispatcher.getQueuedCallsCount() 方法来获取队列中等待执行的任务数。您可以通过调用 dispatcher.getRunningCallsCount() 方法来获取正在执行的任务数。您可以通过调用 dispatcher.getCompletedCallsCount() 方法来获取已完成的任务数。

任务统计

Dispatcher 可以统计任务的执行情况。您可以通过调用 dispatcher.getAverageRequestDuration() 方法来获取平均请求持续时间。您可以通过调用 dispatcher.getMaxRequestDuration() 方法来获取最长请求持续时间。您可以通过调用 dispatcher.getMinRequestDuration() 方法来获取最短请求持续时间。

任务管理

Dispatcher 提供了一系列方法来管理任务。您可以通过调用 dispatcher.enqueue() 方法来将任务添加到任务队列。您可以通过调用 dispatcher.cancelAll() 方法来取消所有任务。您可以通过调用 dispatcher.shutdown() 方法来关闭 Dispatcher。

性能优化

Dispatcher 提供了一系列方法来优化任务执行的性能。您可以通过调用 dispatcher.setMaxRequests() 方法来设置最大并发请求数。您可以通过调用 dispatcher.setMaxRequestsPerHost() 方法来设置每个主机允许的最大并发请求数。您可以通过调用 dispatcher.setUseSynchronousQueue() 方法来启用同步任务队列。