Android Priority Job Queue (Job Manager)（一）

╰+哭是因爲堅強的太久メ 2023-10-17 08:58 99阅读 0赞

**Android Priority Job Queue (Job Manager)（一）**

一、为什么要引入Android Priority Job Queue (Job Manager)？  
如今的APP开发中，几乎绝大多数APP没有不需要后台线程操作和运行的任务，Android平台自身提供了一些后台线程的编程实现模型和API。比如常见的主流后台+线程处理方式：  
A、 AsyncTask，  
B、 Loaders，  
C、 以及更复杂的Service组合线程池（Thread Pool），  
D、Java的Thread结合Handler。  
等等。  
但是以上方式的问题很多，尤其是在耦合到Android本身的Activity或Fragment生命周期时候，要处理各种实际的场景，还有就是当在线程操作中如果处理失败，又该怎么办？有些情况，比如当用户在WIFI或者2G/3G/4G不同网络时候的不同网络加载策略。假设用户在发送一条消息到服务器，但是在线程发送过程中网络中断，在一定时延后网络又接通，此时线程又该如何决定发送任务的再次处理？如果使用Java Thread，Android本身又不允许在主线程外更新UI。如果使用Service，那么还要解决Service和，等等等诸如此类问题全部丢到线程中处理，将会额外但又不得不处理多种状态情况。  
所以，为解决上述问题，就需要引入一种相对完善、可以解决后台+线程的简单易用的线程任务调度管理框架，为此引入Android Priority Job Queue (Job Manager)。  
Android Priority Job Queue (Job Manager)是github上的一个Android开源项目，项目主页是：[https://github.com/yigit/android-priority-jobqueue][https_github.com_yigit_android-priority-jobqueue]  
Android Priority Job Queue (Job Manager)在其项目主页有完整的项目研究背景和作用，简单概括起来就是简化了Android涉及到的后台线程编程开发工作，使得开发者从后台线程繁琐的开发和代码维护中解脱出来，专注于业务逻辑。

二、Android Priority Job Queue (Job Manager)使用简介。

(1) Android Priority Job Queue (Job Manager)首先需要初始化和配置，在初始化和配置阶段，Android Priority Job Queue (Job Manager)类似Java线程池，写一个MyApplication继承自  
Android Application，在此完成初始化。MyApplication.java：

package zhangphil.app;
    
    import android.app.Application;
    import android.util.Log;
    
    import com.birbit.android.jobqueue.JobManager;
    import com.birbit.android.jobqueue.config.Configuration;
    import com.birbit.android.jobqueue.log.CustomLogger;
    
    /**
     * Created by Phil on 2016/10/9.
     */
    public class MyApplication extends Application {
        private JobManager jobManager;
    
        private static MyApplication instance;
    
        public MyApplication() {
            instance = this;
        }
    
        public static MyApplication getInstance() {
            return instance;
        }
    
        @Override
        public void onCreate() {
            super.onCreate();
            getJobManager();// ensure it is created
        }
    
        public synchronized JobManager getJobManager() {
            if (jobManager == null) {
                configureJobManager();
            }
    
            return jobManager;
        }
    
        private void configureJobManager() {
            Configuration.Builder builder = new Configuration.Builder(this)
                    .customLogger(new CustomLogger() {
                        private static final String TAG = "zhangphil job";
    
                        @Override
                        public boolean isDebugEnabled() {
                            return true;
                        }
    
                        @Override
                        public void d(String text, Object... args) {
                            Log.d(TAG, String.format(text, args));
                        }
    
                        @Override
                        public void e(Throwable t, String text, Object... args) {
                            Log.e(TAG, String.format(text, args), t);
                        }
    
                        @Override
                        public void e(String text, Object... args) {
                            Log.e(TAG, String.format(text, args));
                        }
    
                        @Override
                        public void v(String text, Object... args) {
    
                        }
                    })
                    .minConsumerCount(1)//always keep at least one consumer alive
                    .maxConsumerCount(3)//up to 3 consumers at a time
                    .loadFactor(3)//3 jobs per consumer
                    .consumerKeepAlive(120);//wait 2 minute
    
            jobManager = new JobManager(builder.build());
        }
    }

实际上在自己的项目中，Android Priority Job Queue (Job Manager)的初始化工作基本上不用做修改大体按照上面的写就好了，调整的地方在于任务数量这些有关系统性能开销的地方控制。  
写完了记得要在Androidmainfest.xml写到application下面：

<?xml version="1.0" encoding="utf-8"?>
    <manifest xmlns:android="http://schemas.android.com/apk/res/android"
        package="zhangphil.app">
    
        <application
            android:name=".MyApplication"
            android:allowBackup="true"
            android:icon="@mipmap/ic_launcher"
            android:label="@string/app_name"
            android:supportsRtl="true"
            android:theme="@style/AppTheme">
            <activity android:name=".MainActivity">
                <intent-filter>
                    <action android:name="android.intent.action.MAIN" />
    
                    <category android:name="android.intent.category.LAUNCHER" />
                </intent-filter>
            </activity>
        </application>
    
    </manifest>

（2）写一个请求的任务逻辑，这是Android Priority Job Queue (Job Manager)使用的关键地方。首先需要继承自Android Priority Job Queue (Job Manager)得Job类，我写了一个测试的MyJob类，在此类中用于完成后台+线程的任务操作，Android Priority Job Queue (Job Manager)的Job有些类似于Java的Runnable，可以比照Java的Runnable理解Android Priority Job Queue (Job Manager)的Job。耗时线程任务在onRun里面做，MyJob.java：

package zhangphil.app;
    
    import android.os.SystemClock;
    import android.support.annotation.NonNull;
    import android.support.annotation.Nullable;
    import android.util.Log;
    
    import com.birbit.android.jobqueue.Job;
    import com.birbit.android.jobqueue.Params;
    import com.birbit.android.jobqueue.RetryConstraint;
    
    /**
     * Created by Phil on 2016/10/9.
     */
    public class MyJob extends Job {
    
        private String tag;
    
        public MyJob(String tag) {
            super(new Params(500).requireNetwork().persist().groupBy(tag));
            this.tag = tag;
            Log.d(tag, "初始化");
        }
    
        @Override
        public void onAdded() {
            Log.d(tag, "添加任务");
        }
    
        //在这里面放置耗时的后台线程化任务
        @Override
        public void onRun() throws Throwable {
            Log.d(tag, "开始运行...");
    
            int i = 0;
            while (true) {
                i++;
    
                SystemClock.sleep(2000);
                Log.d(tag, String.valueOf(i));
                if (i == 10)
                    break;
            }
    
            Log.d(tag, "完成");
        }
    
        @Override
        protected RetryConstraint shouldReRunOnThrowable(@NonNull Throwable throwable, int runCount, int maxRunCount) {
            // An error occurred in onRun.
            // Return value determines whether this job should retry or cancel. You can further
            // specify a backoff strategy or change the job's priority. You can also apply the
            // delay to the whole group to preserve jobs' running order.
    
            Log.d(tag, "runCount：" + runCount);
    
            return RetryConstraint.createExponentialBackoff(runCount, 1000);
        }
    
        @Override
        protected void onCancel(int cancelReason, @Nullable Throwable throwable) {
    
        }
    }

（3）测试的MainActivity.java：

package zhangphil.app;
    
    import android.app.Activity;
    import android.os.Bundle;
    
    import com.birbit.android.jobqueue.JobManager;
    
    public class MainActivity extends Activity {
    
        private JobManager jobManager;
    
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            //setContentView(R.layout.activity_main);
    
            jobManager=MyApplication.getInstance().getJobManager();
    
            jobManager.addJobInBackground(new MyJob("任务1")); //启动任务，跑！
            //jobManager.addJobInBackground(new MyJob("任务2"));
            //jobManager.addJobInBackground(new MyJob("任务3"));
            //jobManager.addJobInBackground(new MyJob("任务4"));
            //jobManager.addJobInBackground(new MyJob("任务5"));
            //jobManager.addJobInBackground(new MyJob("任务6"));
        }
    }

附录我写的Android线程相关文章：  
【1】《Java线程池：ExecutorService，Executors》链接地址：[http://blog.csdn.net/zhangphil/article/details/43898637][http_blog.csdn.net_zhangphil_article_details_43898637]  
【2】《Java线程池及Future、Callable获得线程返回结果【Java线程池系列2】》链接地址：[http://blog.csdn.net/zhangphil/article/details/49701219][http_blog.csdn.net_zhangphil_article_details_49701219]  
【3】《Java线程池之FutureTask【Java线程池系列3】》链接地址：[http://blog.csdn.net/zhangphil/article/details/49702751][http_blog.csdn.net_zhangphil_article_details_49702751]

[https_github.com_yigit_android-priority-jobqueue]: https://github.com/yigit/android-priority-jobqueue
[http_blog.csdn.net_zhangphil_article_details_43898637]: http://blog.csdn.net/zhangphil/article/details/43898637
[http_blog.csdn.net_zhangphil_article_details_49701219]: http://blog.csdn.net/zhangphil/article/details/49701219
[http_blog.csdn.net_zhangphil_article_details_49702751]: http://blog.csdn.net/zhangphil/article/details/49702751