文章目录

• 一、JobScheduler 提交任务 schedule 方法源码分析
• 二、schedule(JobInfo job, int uId) 方法
• 三、scheduleAsPackage 方法
• 四、startTrackingJob 方法
• 五、JobSchedulerService 源码注释

上一篇博客 【Android 电量优化】电量优化 ( JobScheduler | JobService | AsyncTask ) 中使用了 JobScheduler 进行电量优化 , 将消耗电量的操作 , 都在设定的条件下集中执行 , 达到减少唤醒硬件的频率 , 省电的目的 ; 本篇博客中从源码角度分析上述操作的底层原理 ;

推荐代码查看网站 :

• https://www.androidos.net.cn/sourcecode ( 推荐 )

• http://androidxref.com/

一、JobScheduler 提交任务 schedule 方法源码分析

---

JobScheduler 的功能依赖 JobSchedulerService 系统服务完成 ;

使用 JobScheduler 对象提交任务的方法 schedule(jobInfo) , 最终跨进程调用的 JobSchedulerService 中的 int schedule(JobInfo job, int uId) 方法 ;

二、schedule(JobInfo job, int uId) 方法

---

JobSchedulerService 中的 int schedule(JobInfo job, int uId) 方法解析 :

JobScheduler 的提交任务方法 schedule , 最终调用到 int schedule(JobInfo job, int uId) 方法 , 该调用是跨进程调用的 ;

int schedule(JobInfo job, int uId) 方法 是客户端的 JobScheduler 调用 schedule 方法执行后的入口函数 , 提供一个 JobInfo job 任务 ; 如果任务已经被安排 , 那么取消该任务 , 并使用新传入的该 JobInfo job 参数代替原来的任务 ;

三、scheduleAsPackage 方法

---

在 int schedule(JobInfo job, int uId) 方法中 , 实际调用了 int scheduleAsPackage(JobInfo job, int uId, String packageName, int userId, String tag) 方法 ,

参数说明 :

• job 任务信息
• uId 任务 id
• packageName 包名
• userId 用户 id ;

在上述 scheduleAsPackage 方法中 , 进行了一系列的状态判定 , 如包名不能为空 , 当前任务数量没有超过最大值 MAX_JOBS_PER_APP , 如果上述判定通过 , 就调用 void startTrackingJob(JobStatus jobStatus, JobStatus lastJob) 方法 , 该方法用于追踪任务状态 ;

四、startTrackingJob 方法

---

当我们有一个任务状态对象 , 我们需要插入到 JobStore 时 , 回调 void startTrackingJob(JobStatus jobStatus, JobStatus lastJob) 方法 , 确保所有相关的控制器知道该状态 ;

以下控制器需要知道任务状态 :

• ConnectivityController
• TimeController
• IdleController
• BatteryController
• AppIdleController
• ContentObserverController
• DeviceIdleJobsController

这些控制器都封装在 List mControllers 成员变量中 , 该集合是 JobSchedulerService 的成员变量 ;

上述控制器在 public JobSchedulerService(Context context) 构造函数中初始化并放入 mControllers 集合中 ;

五、JobSchedulerService 源码注释

---

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);
                }
            }
        }
    }
}

该代码路径为 /frameworks/base/services/core/java/com/android/server/job/JobSchedulerService.java , 点击链接可跳转查看完整源码 ;

本文地址：https://blog.csdn.net/han1202012/article/details/107185604