Android Priority Job Queue (Job Manager)：多重不同Job并发执行并在前台获得返回结果（四）

谁借莪１个温暖的怀抱￠ 2023-10-17 09:12 104阅读 0赞

**Android Priority Job Queue (Job Manager)：多重不同Job并发执行并在前台获得返回结果（四）**

在Android Priority Job Queue (Job Manager)中，如果两个或者若干多个完全不同的Job子任务并发执行，如何在前台获得返回结果呢？现在给出一个例子说明。  
假设有两个完全不同的子任务JobA和JobB。当JobA任务完成后返回一个结果给前台回调，同样当任务JobB任务完成后返回一个结果给前台回调使用。  
写两个Job：JobA和JobB。  
JobA.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/11/2.
     */
    
    public class JobA extends Job {
    
        private String tag;
    
        private String result;
    
        public String getResult() {
            return result;
        }
    
        public JobA(String tag) {
            super(new Params(500).requireNetwork().persist().groupBy(tag));
            this.tag = tag;
            Log.d(tag, "构造");
        }
    
        @Override
        public void onAdded() {
            Log.d(tag, "onAdded");
        }
    
        @Override
        public void onRun() throws Throwable {
            Log.d(tag, "开始运行...");
            SystemClock.sleep(3000);
            result = tag + "的结果:" + System.currentTimeMillis();
            Log.d(tag, "完成:" + result);
        }
    
        @Override
        protected void onCancel(int cancelReason, @Nullable Throwable throwable) {
    
        }
    
        @Override
        protected RetryConstraint shouldReRunOnThrowable(@NonNull Throwable throwable, int runCount, int maxRunCount) {
            return null;
        }
    }

JobB.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/11/2.
     */
    
    public class JobB extends Job {
    
        private String tag;
    
        private String result;
    
        public String getResult() {
            return result;
        }
    
        public JobB(String tag) {
            super(new Params(500).requireNetwork().persist().groupBy(tag));
            this.tag = tag;
            Log.d(tag, "构造");
        }
    
        @Override
        public void onAdded() {
            Log.d(tag, "onAdded");
        }
    
        @Override
        public void onRun() throws Throwable {
            Log.d(tag, "开始运行...");
            SystemClock.sleep(3000);
            result = tag + "的结果:" + System.currentTimeMillis();
            Log.d(tag, "完成:" + result);
        }
    
        @Override
        protected void onCancel(int cancelReason, @Nullable Throwable throwable) {
    
        }
    
        @Override
        protected RetryConstraint shouldReRunOnThrowable(@NonNull Throwable throwable, int runCount, int maxRunCount) {
            return null;
        }
    }

前台回调获得结果：

package zhangphil.app;
    
    import android.support.annotation.NonNull;
    import android.support.annotation.Nullable;
    import android.support.v7.app.AppCompatActivity;
    import android.os.Bundle;
    import android.util.Log;
    
    import com.birbit.android.jobqueue.Job;
    import com.birbit.android.jobqueue.JobManager;
    import com.birbit.android.jobqueue.callback.JobManagerCallback;
    
    public class MainActivity extends AppCompatActivity {
    
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            //setContentView(R.layout.activity_main);
    
            JobManager jobManager = MyApplication.getInstance().getJobManager();
    
            JobA a = new JobA("任务->A");
            JobA b = new JobA("任务->B");
            jobManager.addJobInBackground(a);
            jobManager.addJobInBackground(b);
    
            jobManager.addCallback(new JobManagerCallback() {
                @Override
                public void onJobAdded(@NonNull Job job) {
    
                }
    
                @Override
                public void onJobRun(@NonNull Job job, int resultCode) {
    
                }
    
                @Override
                public void onJobCancelled(@NonNull Job job, boolean byCancelRequest, @Nullable Throwable throwable) {
    
                }
    
                @Override
                public void onDone(@NonNull Job job) {
                    if (job instanceof JobA) {
                        JobA a = (JobA) job;
                        Log.d("返回", a.getResult());
                    }
    
                    if (job instanceof JobB) {
                        JobB b = (JobB) job;
                        Log.d("返回", b.getResult());
                    }
                }
    
                @Override
                public void onAfterJobRun(@NonNull Job job, int resultCode) {
    
                }
            });
        }
    }

需要注意须用instanceof判断回调的实例是具体哪一个。

代码运行结果如图（添加关键词‘任务’过滤）：

![Center][]

关于MyApplication的配置和写法和附录文章4,5,6相同。

附录：  
【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]  
【4】《Android Priority Job Queue (Job Manager)（一）》链接地址：[http://blog.csdn.net/zhangphil/article/details/52777196][http_blog.csdn.net_zhangphil_article_details_52777196]  
【5】《Android Priority Job Queue (Job Manager)：线程任务的容错重启机制（二）》链接地址：[http://blog.csdn.net/zhangphil/article/details/52778525][http_blog.csdn.net_zhangphil_article_details_52778525]  
【6】《 Android Priority Job Queue (Job Manager)：后台线程任务结果传回前台（三）》链接：[http://blog.csdn.net/zhangphil/article/details/52787588][http_blog.csdn.net_zhangphil_article_details_52787588]

[Center]: https://img-blog.csdn.net/20161102112138069?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQv/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/Center
[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
[http_blog.csdn.net_zhangphil_article_details_52777196]: http://blog.csdn.net/zhangphil/article/details/52777196
[http_blog.csdn.net_zhangphil_article_details_52778525]: http://blog.csdn.net/zhangphil/article/details/52778525
[http_blog.csdn.net_zhangphil_article_details_52787588]: http://blog.csdn.net/zhangphil/article/details/52787588