推荐代码查看网站 :
上一篇博客 【Android 电量优化】JobScheduler 源码分析 ( JobSchedulerService 源码分析 | Android 源码在线网址推荐 ) 中讲解了JobScheduler 调用 schedule 方法底层调用 :
本篇博客中讲解了 ConnectivityController 中对任务状态的处理 ;
上一篇博客中在 JobSchedulerService 中最终在 startTrackingJob 方法中 , 调用了 StateController 控制器的 maybeStartTrackingJobLocked 方法 ;
这里以 ConnectivityController 连接控制器为例 , 该类是 StateController 的子类 , 其在 JobSchedulerService 中相关源码如下 :
/** 控制器集合 , 提醒该 Service 服务区更新任务. */
List<StateController> mControllers;
// 后续会遍历该集合 , 遍历出的元素会调用 maybeStartTrackingJobLocked 方法
mControllers = new ArrayList<StateController>();
// 网络控制器
mControllers.add(ConnectivityController.get(this));
// 调用控制器的 maybeStartTrackingJobLocked 函数
controller.maybeStartTrackingJobLocked(jobStatus, lastJob);
在 ConnectivityController 中的 void maybeStartTrackingJobLocked(JobStatus jobStatus, JobStatus lastJob) 方法 , 该方法作用是更新所有该控制器追踪的任务 , 被追踪的任务都在 ArrayList<JobStatus> mTrackedJobs 集合中 , 该集合在类成员变量中维护 ;
会对传入的任务状态 JobStatus jobStatus 参数进行一系列判定 , 如果判定通过 , 就会执行
在 ConnectivityController(StateChangedListener stateChangedListener, Context context, Object lock) 构造方法中 , 注册了广播接收者 , 接收 ConnectivityManager.CONNECTIVITY_ACTION 广播 , 这是监听网络状态改变发出的广播 ;
// 注册广播接收者 , 接收 ConnectivityManager.CONNECTIVITY_ACTION 广播 , 这是监听网络状态改变发出的广播
final IntentFilter intentFilter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
mContext.registerReceiverAsUser(
mConnectivityReceiver, UserHandle.SYSTEM, intentFilter, null, null);
在 mConnectivityReceiver 广播接收者中 , 接收到 ConnectivityManager.CONNECTIVITY_ACTION 广播 , 网络状态改变后 , 就会调 updateTrackedJobs(-1) 函数 ;
public void onReceive(Context context, Intent intent) {
// 接收到 ConnectivityManager.CONNECTIVITY_ACTION 广播
// 网络状态改变后 , 就会调用该函数
updateTrackedJobs(-1);
}
void updateTrackedJobs(int uid) 方法的作用是 : 更新所有该控制器追踪的任务 , 被追踪的任务都在 ArrayList mTrackedJobs 集合中 ;
int uid 参数含义 : 更新该 uid 对应的任务 , 如果传入 -1 那么就是更新所有的被追踪任务 ;
在该方法中 , 遍历所有的被监听的任务集合 , ArrayList mTrackedJobs , 如果有一个任务发生改变 , 就回调 状态改变监听器 mStateChangedListener , 该 mStateChangedListener 定义在父类 StateController 中 ; mStateChangedListener 实际上是 JobSchedulerService ;
mStateChangedListener.onControllerStateChanged();
/**
* 处理连接状态改变
* 每个应用可以有不同的默认网络或不同的连接状态 , 根据用户需要的网络策略 , 因此我们需要检查每个 uid 要素的约束 .
*/
public class ConnectivityController extends StateController implements
ConnectivityManager.OnNetworkActiveListener {
// 连接管理器系统服务
private final ConnectivityManager mConnManager;
// 网络策略管理器系统服务
private final NetworkPolicyManager mNetPolicyManager;
// 任务状态集合
@GuardedBy("mLock")
private final ArrayList<JobStatus> mTrackedJobs = new ArrayList<JobStatus>();
// 连接控制器构造函数
private ConnectivityController(StateChangedListener stateChangedListener, Context context,
Object lock) {
// 调用父类的 StateController 的构造方法
super(stateChangedListener, context, lock);
// 获取连接管理器系统服务
mConnManager = mContext.getSystemService(ConnectivityManager.class);
// 获取网络策略系统服务
mNetPolicyManager = mContext.getSystemService(NetworkPolicyManager.class);
// 注册广播接收者 , 接收 ConnectivityManager.CONNECTIVITY_ACTION 广播 , 这是监听网络状态改变发出的广播
final IntentFilter intentFilter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
mContext.registerReceiverAsUser(
mConnectivityReceiver, UserHandle.SYSTEM, intentFilter, null, null);
// 注册网络策略监听器
mNetPolicyManager.registerListener(mNetPolicyListener);
}
@Override
public void maybeStartTrackingJobLocked(JobStatus jobStatus, JobStatus lastJob) {
// 判断任务的一系列状态
if (jobStatus.hasConnectivityConstraint() || jobStatus.hasUnmeteredConstraint()
|| jobStatus.hasNotRoamingConstraint()) {
updateConstraintsSatisfied(jobStatus);
// 将任务状态放入 ArrayList<JobStatus> mTrackedJobs 集合中
mTrackedJobs.add(jobStatus);
}
}
// 在构造函数中注册的广播接收者
private BroadcastReceiver mConnectivityReceiver = new BroadcastReceiver() {
@Override
public void onReceive(Context context, Intent intent) {
// 接收到 ConnectivityManager.CONNECTIVITY_ACTION 广播
// 网络状态改变后 , 就会调用该函数
updateTrackedJobs(-1);
}
};
/**
* 更新所有该控制器追踪的任务 ;
* 被追踪的任务都在 ArrayList<JobStatus> mTrackedJobs 集合中
*
* @param uid 更新该 uid 对应的任务 , 如果传入 -1 那么就是更新所有的被追踪任务
*/
private void updateTrackedJobs(int uid) {
synchronized (mLock) {
boolean changed = false;
// 遍历所有的被监听的任务集合 , ArrayList<JobStatus> mTrackedJobs
for (int i = 0; i < mTrackedJobs.size(); i++) {
final JobStatus js = mTrackedJobs.get(i);
if (uid == -1 || uid == js.getSourceUid()) {
changed |= updateConstraintsSatisfied(js);
}
}
// 如果判断的改变为 true , 就回调 状态改变监听器 mStateChangedListener
// 该 mStateChangedListener 定义在父类 StateController 中
// 状态控制器创建时 , 会传入 mStateChangedListener
if (changed) {
mStateChangedListener.onControllerStateChanged();
}
}
}
}
该代码路径为 frameworks/base/services/core/java/com/android/server/job/controllers/ConnectivityController.java , 点击链接可跳转查看完整源码 ;