【Android 电量优化】JobScheduler 相关源码分析 ( JobSchedulerService 源码分析 | Android 源码在线网址推荐 )

public class JobSchedulerService extends com.android.server.SystemService
        implements StateChangedListener, JobCompletedListener {
    /** 任务的主要集合. */
    final JobStore mJobs;
    /** 控制器集合 , 提醒该 Service 服务区更新任务. */
    List<StateController> mControllers;
    /**
     * 初始化系统服务
     * <p>
     * 子类必须定义一个单参数的构造函数 , 接收 Context context 参数 , 并且传递给父类
     * </p>
     *
     * @param context 系统服务上下文对象
     */
    public JobSchedulerService(Context context) {
        super(context);
        mHandler = new JobHandler(context.getMainLooper());
        mConstants = new Constants(mHandler);
        mJobSchedulerStub = new JobSchedulerStub();
        mJobs = JobStore.initAndGet(this);
        // 创建控制器集合
        // 后续会遍历该集合 , 遍历出的元素会调用 maybeStartTrackingJobLocked 方法
        mControllers = new ArrayList<StateController>();
        // 网络控制器
        mControllers.add(ConnectivityController.get(this));
        mControllers.add(TimeController.get(this));
        mControllers.add(IdleController.get(this));
        // 电量控制器
        mControllers.add(BatteryController.get(this));
        mControllers.add(AppIdleController.get(this));
        mControllers.add(ContentObserverController.get(this));
        mControllers.add(DeviceIdleJobsController.get(this));
    }
    // JobScheduler 的提交任务方法 schedule , 最终调用到该方法
    // 跨进程方式调用 
    // 这是客户端的 JobScheduler 调用 schedule 方法执行后的入口函数 , 提供一个 JobInfo job 任务 ; 
    // 如果任务已经被安排 , 那么取消该任务 , 并使用新传入的该 JobInfo job 参数代替原来的任务 ; 
    public int schedule(JobInfo job, int uId) {
        return scheduleAsPackage(job, uId, null, -1, null);
    }
    // 实际调用的方法 , 传入 JobInfo job 任务信息 , uId 任务 id , packageName 包名 , userId 用户 id , 
    public int scheduleAsPackage(JobInfo job, int uId, String packageName, int userId,
            String tag) {
        // 创建任务状态
        JobStatus jobStatus = JobStatus.createFromJobInfo(job, uId, packageName, userId, tag);
  // ... 省略       
        JobStatus toCancel;
        synchronized (mLock) {
            // 判定状态是否合法 , 包名不能为空 , 当前任务数量没有超过最大值 MAX_JOBS_PER_APP
            if (ENFORCE_MAX_JOBS && packageName == null) {
                if (mJobs.countJobsForUid(uId) > MAX_JOBS_PER_APP) {
                    Slog.w(TAG, "Too many jobs for uid " + uId);
                    // 如果多于最大任务数 , 就要抛出异常 
                    throw new IllegalStateException("Apps may not schedule more than "
                                + MAX_JOBS_PER_APP + " distinct jobs");
                }
            }
            toCancel = mJobs.getJobByUidAndJobId(uId, job.getId());
            if (toCancel != null) {
                cancelJobImpl(toCancel, jobStatus);
            }
            // 如果上述判定通过 , 就调用该方法 , 该方法用于追踪任务状态 
            startTrackingJob(jobStatus, toCancel);
        }
        mHandler.obtainMessage(MSG_CHECK_JOB).sendToTarget();
        return JobScheduler.RESULT_SUCCESS;
    }
    /**
     * 当我们有一个任务状态对象 , 我们需要插入到 JobStore 时 , 回调该方法 , 
     * 确保所有相关的控制器知道它 ;
     */
    private void startTrackingJob(JobStatus jobStatus, JobStatus lastJob) {
        synchronized (mLock) {
          // 将本次调度的任务加入到 JobStore mJobs 集合中
            final boolean update = mJobs.add(jobStatus);
            if (mReadyToRock) {
              // 遍历控制器集合 List<StateController> mControllers
                for (int i = 0; i < mControllers.size(); i++) {
                    StateController controller = mControllers.get(i);
                    if (update) {
                        controller.maybeStopTrackingJobLocked(jobStatus, null, true);
                    }
                    // 调用控制器的 maybeStartTrackingJobLocked 函数 
                    controller.maybeStartTrackingJobLocked(jobStatus, lastJob);
                }
            }
        }
    }
}