文档章节

KJFrameForAndroid框架学习——多线程管理

爱看博客
 爱看博客
发布于 2015/10/22 10:06
字数 1625
阅读 14
收藏 0

在Android开发中,由于不能再UI线程中做耗时操作,常常需要开启线程来做一些操作。但是这样一来就产生了一个问题,就是大量的线程并发执行,造成了线程维护的开销进而使得代码质量下降手机发烫又耗电。让我们来看一下KJFrameForAndroid框架是如何解决这个问题的。
KJFrameForAndroid框架项目地址:https://github.com/kymjs/KJFrameForAndroid

其实Android提供了一套专门用于异步处理的类,就是我们熟悉又模式的AsynTask类。
AsynTask类就是对Thread类的一个封装,并且加入了一些新的方法。那么我们先来看一下它对于Thread请求的一系列管理与封装。
在jdk中有这样一个集合类叫:BlockingQueue<>它是一个 Queue<E>的子类,支持两个附加操作的 Queue,这两个操作是:获取元素时等待队列变为非空,以及存储元素时等待空间变得可用。
BlockingQueue 方法以四种形式出现,对于不能立即满足但可能在将来某一时刻可以满足的操作,这四种形式的处理方式不同:第一种是抛出一个异常,第二种是返回一个特殊值(null 或 false,具体取决于操作),第三种是在操作可以成功前,无限期地阻塞当前线程,第四种是在放弃前只在给定的最大时间限制内阻塞。


我们来看一下在jdk中关于这个类的介绍:

BlockingQueue 不接受 null 元素。试图 add、put 或 offer 一个 null 元素时,某些实现会抛出 NullPointerException。null 被用作指示 poll 操作失败的警戒值。

好,为什么要讲这个集合类呢?因为这与我们接下来要讲的线程池维护有着莫大的关系。

?
1
2
     // 静态阻塞式队列,用来存放待执行的任务,初始容量:8个
     private  static  final  BlockingQueue<Runnable> mPoolWorkQueue =  new  LinkedBlockingQueue<Runnable>( 8 );

这里是KJFrameForAndroid开发框架中对于线程队列的维护对象,通过这个线程队列将所有线程放置在一个静态阻塞式队列中保存起来。
然而,仅仅是保存起来还不够,因为线程需要执行,我们必须要让线程进入到CPU工作间才行,这时KJFrameForAndroid使用了jdk中的另一个类ThreadPoolExecutor来管理并使用并发启动这些线程
来看一下在KJFrameForAndroid中对于这个类对象的创建

?
1
2
3
4
5
6
7
     /**
      * 并发线程池任务执行器,可以用来并行执行任务<br>
      * 与mSerialExecutor(串行)相对应
      */
     public  static  final  Executor mThreadPoolExecutor =  new  ThreadPoolExecutor(
             CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE,
             TimeUnit.SECONDS, mPoolWorkQueue, mThreadFactory);

通过注释,我们还可以看到KJFrameForAndroid框架其实还有一种并行执行线程的方式,这里暂时不讲,我们看看这个类的构造方法在jdk中的解释:

那么至此我们有了并发任务执行器和线程池队列,最后就只需要将线程执行起来就行了。ThreadPoolExecutor类是一个实现了执行器Executor接口的类,那么它也就有一个execute方法去执行线程,我们所要做的就是调用这个类来执行它就可以了。

接下来我们来看一下如何让线程执行完成后又回到UI线程去做界面处理的。

还是看源码,以下是摘自KJFrameForAndroid开源框架中的一段代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
/*********************** start 一个完整的执行周期 ***************************/
     /**
      * 在doInBackground之前调用,用来做初始化工作 所在线程:UI线程
      */
     protected  void  onPreExecute() {}
     /**
      * 这个方法是我们必须要重写的,用来做后台计算 所在线程:后台线程
      */
     protected  abstract  Result doInBackground(Params... params);
     /**
      * 打印后台计算进度,onProgressUpdate会被调用<br>
      * 使用内部handle发送一个进度消息,让onProgressUpdate被调用
      */
     protected  final  void  publishProgress(Progress... values) {
         if  (!isCancelled()) {
             mHandler.obtainMessage(MESSAGE_POST_PROGRESS,
                     new  KJTaskResult<Progress>( this , values))
                     .sendToTarget();
         }
     }
     /**
      * 在publishProgress之后调用,用来更新计算进度 所在线程:UI线程
      */
     protected  void  onProgressUpdate(Progress... values) {}
     /**
      * 任务结束的时候会进行判断:如果任务没有被取消,则调用onPostExecute;否则调用onCancelled
      */
     private  void  finish(Result result) {
         if  (isCancelled()) {
             onCancelled(result);
         else  {
             onPostExecute(result);
         }
         mStatus = Status.FINISHED;
     }
     /**
      * 在doInBackground之后调用,用来接受后台计算结果更新UI 所在线程:UI线程
      */
     protected  void  onPostExecute(Result result) {}
     /**
      * 所在线程:UI线程<br>
      * doInBackground执行结束并且{@link #cancel(boolean)} 被调用。<br>
      * 如果本函数被调用则表示任务已被取消,这个时候onPostExecute不会再被调用。
      */
     protected  void  onCancelled(Result result) {}
     /*********************** end 一个完整的执行周期 ***************************/

在这里我们看到了三个非常熟悉的函数:doInBackground、onPostExecute、onProgressUpdate
没错,这三个函数正式SyncTask中被我们使用的三个方法(如果你还不知道,请搜索Android开发中SyncTask用法)接着我们再看看他们是如何被调用的:
这里声明了一个线程任务被执行的方法,实际上也就是doInBackground、被调用的方法:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
/**
      * 必须在UI线程调用此方法<br>
      * 通过这个方法我们可以自定义KJTaskExecutor的执行方式,串行or并行,甚至可以采用自己的Executor 为了实现并行,
      * asyncTask.executeOnExecutor(KJTaskExecutor.mThreadPoolExecutor, params);
      */
     public  final  KJTaskExecutor<Params, Progress, Result> executeOnExecutor(
             Executor exec, Params... params) {
         if  (mStatus != Status.PENDING) {
             switch  (mStatus) {
             case  RUNNING:
                 throw  new  IllegalStateException(
                         "Cannot execute task:"
                                 " the task is already running." );
             case  FINISHED:
                 throw  new  IllegalStateException(
                         "Cannot execute task:"
                                 " the task has already been executed "
                                 "(a task can be executed only once)" );
             default :
                 break ;
             }
         }
         mStatus = Status.RUNNING;
         onPreExecute();
         mWorker.mParams = params;
         exec.execute(mFuture); // 原理{@link #execute(Runnable runnable)}
         // 接着会有#onProgressUpdate被调用,最后是#onPostExecute
         return  this ;
     }

而onProgressUpdate实际上是在这个handle中被调用了。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
/**
      * KJTaskExecutor内部Handler,用来发送后台计算进度更新消息和计算完成消息
      */
     private  static  class  InternalHandler  extends  Handler {
         @Override
         @SuppressWarnings ({  "unchecked" "rawtypes"  })
         public  void  handleMessage(Message msg) {
             KJTaskResult result = (KJTaskResult) msg.obj;
             switch  (msg.what) {
             case  MESSAGE_POST_RESULT:
                 result.mTask.finish(result.mData[ 0 ]);
                 break ;
             case  MESSAGE_POST_PROGRESS:
                 result.mTask.onProgressUpdate(result.mData);
                 break ;
             }
         }
     }
有关本类的完整代码可以查看 https://github.com/kymjs/KJFrameForAndroid/blob/master/KJLibrary/src/org/kymjs/aframe/core/KJTaskExecutor.java

版权声明:本文原创,转载请注明来自 http://kymjs.com/

本文转载自:http://blog.csdn.net/kymjs/article/details/39295643

共有 人打赏支持
爱看博客
粉丝 5
博文 103
码字总数 23887
作品 0
深圳

暂无文章

文件的压缩与解压(linux)

Linux下*.tar.gz文件解压缩命令 1.压缩命令:   命令格式:tar -zcvf 压缩后文件名.tar.gz 被压缩文件名 可先切换到当前目录下。压缩文件名和被压缩文件名都可加入路径。 2.解压缩命令: ...

qimh
36分钟前
3
0
invalid character found in the request target 异常

这个异常时因为Tomcat 9不支持请求格式出现“{”等非法字符的问题 因为tomcat版本问题遇到的坑,记录一下。 问题 今天由于要测试一下订单详情页的异步查询,在本地起了一个服务,发送的请求是...

edwardGe
40分钟前
4
0
发现抓包软件fiddler的bug

1个请求他跳转之后,直接400,被拦在了Apache,使用fiddler 的,replay requests 是同样的结果,但是replay composer确是正常的。 也就是说这replay requests 是发原来的包,replay composer...

NLGBZJ
50分钟前
1
0
linux screen 命令详解

shell关闭后, 主机仍然运行 screen命令 启动jenkins以后, screen, 然后按ctrl+a 再按d 这样暂停了子界面, 这时候回到了父界面 用screen –ls查看目前子界面的状态 [root@free /]# screen -l...

SuShine
51分钟前
4
0
mac机器切换无线网络导致网页不能打开的问题

问题: 公司和家里使用不同的WI-FI,每次从家到公司时自动切换网络后,公司的许多地址不能访问, ping域名是可以ping同的,但是网页却打不开... 问题分析: 初步猜想是DNS缓存的问题? 对于MAC系统没...

Lennie002
53分钟前
2
0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部