【Android 电量优化】JobScheduler 源码分析 ( JobServiceContext 源码分析 | 闭环操作总结 | 用户提交任务 | 广播接收者接受相关广播触发任务执行 )★

文章目录

一、JobServiceContext 引入

二、JobServiceContext 源码分析

三、用户在应用层如何使用 JobScheduler

四、用户提交任务

五、广播接收者监听广播触发 JobService 执行任务

推荐代码查看网站 :

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

http://androidxref.com/

一、JobServiceContext 引入

上一篇博客 【Android 电量优化】JobScheduler 相关源码分析 ( JobSchedulerService 源码分析 | 任务检查 | 任务执行 ) 中在 JobSchedulerService 中的 assignJobsToContextsLocked 方法中 , 有如下代码 :

// /frameworks/base/services/core/java/com/android/server/job/JobSchedulerService.java 中的代码
mActiveServices.get(i).executeRunnableJob(pendingJob)

mActiveServices 就是 JobServiceContext 集合 , 上述方法调用了 JobServiceContext 的 executeRunnableJob 方法 , 目的是要执行传入的 pendingJob 任务 ;

二、JobServiceContext 源码分析

在 JobServiceContext 类的 executeRunnableJob 方法的作用 : 该方法传递一个 Job 任务给 JobServiceContext 执行 , 调用者需要先检查如下两个条件 :

当前是否有运行中的任务 , getRunningJob() 必须为空 ;

同时还需要确保该 JobServiceContext 上下文是有效的 ;

在该方法中创建了 Intent , 并使用该意图绑定了一个服务 , 这个服务就是创建 JobInfo 时 , 开发者自定义的 JobService 服务 , 提交任务时需要提交该服务 ;

绑定服务 , 执行 JobService 服务中的 onStartJob 方法

截止到此处 , 基本 JobScheduler 整个运行的闭环 , 进行了简单的源码分析 , 没有深入分析 , 仅限于简单了解 ;

public class JobServiceContext extends IJobCallback.Stub implements ServiceConnection {
  // ... 
    /**
     * 该方法传递一个 Job 任务给 JobServiceContext 执行 . 
     * 调用者需要先检查当前是否有运行中的任务 , getRunningJob() 为空 ; 
     * 并且确保该 JobServiceContext 上下文是有效的 ; 
     * 
     * @param 将要运行的任务的状态 ;
     * @return True 如果该任务是有效的 , 并且正在执行 ; 
     *      False 如果该任务不能被执行 ; 
     */
    boolean executeRunnableJob(JobStatus job) {
        synchronized (mLock) {
            // ...
    // 此处创建了 Intent , 并使用该意图绑定了一个服务 
            final Intent intent = new Intent().setComponent(job.getServiceComponent());
            // 使用上述意图 Intent 绑定服务 
            // 这个服务就是创建 JobInfo 时 , 开发者自定义的 JobService 服务 , 提交任务时需要提交该服务  
            boolean binding = mContext.bindServiceAsUser(intent, this,
                    Context.BIND_AUTO_CREATE | Context.BIND_NOT_FOREGROUND,
                    new UserHandle(job.getUserId()));
            // ... 
            try {
              // 启动服务 , 会执行 JobService 服务中的 onStartJob 方法
                mBatteryStats.noteJobStart(job.getBatteryName(), job.getSourceUid());
            } catch (RemoteException e) {
                // Whatever.
            }
            mJobPackageTracker.noteActive(job);
            mAvailable = false;
            return true;
        }
    }
}

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

三、用户在应用层如何使用 JobScheduler

先讲解用户在应用层如何使用 JobScheduler :

在 【Android 电量优化】电量优化 ( JobScheduler | JobService | AsyncTask ) 博客中 , 讲解了 JobScheduler 如何使用 ;

获取服务 : 首先获取系统的 JobScheduler 服务 , 就是之前分析的 JobSchedulerService 类 ;

创建任务 : 创建 JobInfo 任务信息 , 使用 JobScheduler 提交该任务 ; mJobScheduler.schedule(jobInfo) ;

自定义 JobService : 开发者在应用中自定义 JobService 服务 ;

服务执行 : 系统会在合适的时间调用 JobService 服务的 boolean onStartJob(JobParameters params) 方法 ;

其中涉及到两个入口 , 一个是用户提交任务 , 另一个是系统在某个时间回调 JobService 服务中的开始执行任务方法 ;

主要针对上述两个入口进行分析 ;

用户提交任务的驱动事件是开发者写的提交任务的代码 ;

系统回调 JobService 服务的驱动事件 , 是用户对手机的操作 , 如插拔电源线 , 切换 WIFI 网络等操作 , 这些操作触发广播 , 相应广播接收者收到这些广播 , 就会触发一系列相关的操作 ;

四、用户提交任务

分析用户提交任务 :

【Android 电量优化】JobScheduler 相关源码分析 ( JobSchedulerService 源码分析 | Android 源码在线网址推荐 ) 博客中讲解了如下内容 :

JobScheduler 提交任务的方法 schedule(jobInfo) , 最终调用的是 JobSchedulerService 中的 schedule 方法 ;

在 schedule 方法中调用了 scheduleAsPackage 方法 , 传入任务相关信息 , 进行了一系列的状态判定 ;

在 scheduleAsPackage 方法中调用 startTrackingJob 方法 , 该方法中遍历所有的状态控制器 , 确保所有相关的控制器知道该状态 ;

【Android 电量优化】JobScheduler 相关源码分析 ( ConnectivityController 底层源码分析 | 构造函数 | 追踪任务更新 | 注册接收者监听连接变化 ) 博客中接着上面的博客继续分析 :

在 startTrackingJob() 方法中 , 调用状态控制器 StateController 的 maybeStartTrackingJobLocked 方法 , 该方法的作用是更新所有对应的状态控制器监听的任务 ;

五、广播接收者监听广播触发 JobService 执行任务

广播接收者监听广播 : 这是触发系统回调 JobService 服务的入口 ;

在 【Android 电量优化】JobScheduler 相关源码分析 ( ConnectivityController 底层源码分析 | 构造函数 | 追踪任务更新 | 注册接收者监听连接变化 ) 博客中分析到

注册广播接收者 : ConnectivityController 中注册了广播接收者 , 用于监听 ConnectivityManager.CONNECTIVITY_ACTION 广播 , 这是网络状态改变后发出的广播 ;

广播接收者收到网络状态改变的广播后 , 会调用 updateTrackedJobs(-1) 方法 ;

该方法会更新所有对网络状态敏感的任务 , 例如有的任务要求在 WIFI 条件下执行 , 此时就会触发该任务的状态改变 ;

updateTrackedJobs 方法中又会调用 状态改变监听器 mStateChangedListener 的 onControllerStateChanged 方法 ;

状态改变监听器 mStateChangedListener 就是 JobSchedulerService 类 ;

【Android 电量优化】JobScheduler 相关源码分析 ( JobSchedulerService 源码分析 | 任务检查 | 任务执行 ) 博客中讲解后续操作 :

在实现的 StateChangedListener 接口的 onControllerStateChanged() 回调方法中 , 使用 JobHandler mHandler 发送了 MSG_CHECK_JOB 消息 ;

在 JobHandler 中接收上述消息 , 并检查任务 , 最终调用 maybeRunPendingJobsH() 方法 , 执行任务 ;

在 maybeRunPendingJobsH 方法中 , 调用 assignJobsToContextsLocked , 执行任务 ;

在 assignJobsToContextsLocked 方法中 , 最终调用了 JobServiceContext 执行 executeRunnableJob(pendingJob) 方法 , 用于执行 pendingJob 任务 ;

最终在 JobServiceContext 中绑定用户自定义的 JobService , 开始执行任务 , 会自动回调下面代码中的 onStartJob 方法 ;

public class BpJobService extends JobService {
    @Override
    public boolean onStartJob(JobParameters params) {
        // 启动 AsyncTask 异步任务处理工作
        new JobAsyncTask().execute(params);
        return false;
    }
    // ... 省略部分代码
}

本篇博客涉及到的源码 :

/frameworks/base/services/core/java/com/android/server/job/JobSchedulerService.java

frameworks/base/services/core/java/com/android/server/job/controllers/ConnectivityController.java

/frameworks/base/services/core/java/com/android/server/job/JobServiceContext.java