android非RxJava环境下使用Handler实现预加载

在进行Android客户端界面开发时,我们常常会需要将从服务端获取的数据展示到页面布局上,由于数据显示到布局的前置条件是页面布局已初始化完成,否则会出现空指针异常,所以一般我们需要将网络请求放在布局初始化完成之后。
传统的页面加载流程是:

问题:

如果加载的UI布局比较复杂,或者初始化逻辑执行的时间比较多,那么网络请求开始执行的时间就比较晚,最终完成页面加载的时间就比较长。
如果页面初始化和网络加载能同时进行,等两者都执行结束后,再在布局上展示网络数据,这样我们就可以缩短整个页面的加载时间了。
所以,我们期望的页面加载流程是:

这个流程我们称之为:预加载

预加载的目标任务可以是一个网络请求,也可以是其它一些耗时操作,例如:加载一张图片到控件上展示
在实现预加载方案之前,我们需要了解一下Handler工作机制中的SyncBarrier概念,对Barrier概念了解可以看这篇文章中对“同步分割栏”的介绍, 此处我们简单理解为:

在MessageQueue中添加一个特殊的msg,将这个msg作为一个标记,在这个标记被移除之前,当前MessageQueue队列中排在它后面的其它(非async) 的message不会被handler处理。

我们可以先不理会什么是 非async 的message,若需要了解更多,这篇文章中对“同步分割栏”的介绍中也有相关介绍。

利用这个特性,我们可以:

启动一个HandlerThread来异步执行网络请求
设置一个标记SyncBarrier,此后在message将一直在messageQueue中不被执行
网络请求成功后,post一个任务来执行展示数据
布局初始化成功后,移除SyncBarrier
将展示数据的任务post到ui线程来执行
步骤3和步骤4的先后顺序可以交换

其中,在android api 22及之前,设置标记SyncBarrier可以由

HandlerThread.getLooper().postSyncBarrier();

在android api 23以后,需要调用的方法为:

HandlerThread.getLooper().getQueue().postSyncBarrier();

同样的,移除标记的方法分别为:

HandlerThread.getLooper().removeSyncBarrier(token);
HandlerThread.getLooper().getQueue().removeSyncBarrier(token);

不幸的是:这些方法都是@hide的,无法直接调用。
幸运的是:我们还有反射

封装工具类如下: PreLoader.java

import android.os.Handler;
import android.os.HandlerThread;
import android.os.Looper;
import android.os.MessageQueue;

import java.lang.reflect.Method;

/**
* 使用Handler方式实现的预加载
* @author billy.qi
*/
public class PreLoader {

 private int token;
 private Handler mainThreadHandler;//用于将结果处理的task放在主线程中执行
 private HandlerThread handlerThread;//提供一个异步线程来运行预加载任务
 private Handler handler;//预加载使用的handler

 private PreLoader(final Runnable task) {
 mainThreadHandler = new Handler(Looper.getMainLooper());
 handlerThread = new HandlerThread("pre-loader") {
  @Override
  protected void onLooperPrepared() {
  super.onLooperPrepared();
  handler = new Handler();
  handler.post(task);
  //设置同步分割,后面post进来的sync为true的message将暂停执行
  Looper looper = handlerThread.getLooper();
  if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.M) {
   postSyncBarrier(looper.getQueue());
  } else {
   postSyncBarrier(looper);
  }
  }
 };
 handlerThread.start();
 }

 /**
 * 开启预加载
 * 比如:开始网络请求(在HandlerThread中执行)
 * @param task 预加载任务
 */
 public static PreLoader preLoad(Runnable task) {
 return new PreLoader(task);
 }

 /**
 * 处理加载结果, 一般在预加载任务处理完成后调用
 * 由于有handler所在的messageQueue设置了同步分割(SyncBarrier),该task
 * @param task 在主线程中执行的任务
 */
 public void performResultTask(final Runnable task) {
 if (handler != null) {
  handler.post(new Runnable() {
  @Override
  public void run() {
   mainThreadHandler.post(task);
  }
  });
 }
 }

 /**
 * 可以开始执行预加载结果处理
 */
 public void readyToGetData() {
 Looper looper = handlerThread.getLooper();
 if (android.os.Build.VERSION.SDK_INT >= android.os.Build.VERSION_CODES.M) {
  removeSyncBarrier(looper.getQueue());
 } else {
  removeSyncBarrier(looper);
 }
 }

 private void postSyncBarrier(Object obj) {
 try{
  Method method = MessageQueue.class.getMethod("postSyncBarrier");
  token = (int) method.invoke(obj);
 } catch(Exception e) {
  e.printStackTrace();
 }
 }

 private void removeSyncBarrier(Object obj) {
 try{
  Method method = MessageQueue.class.getMethod("removeSyncBarrier", int.class);
  method.invoke(obj, token);
 } catch(Exception e) {
  e.printStackTrace();
 }
 }

 public void destroy() {
 handlerThread.quit();
 handlerThread = null;
 handler = null;
 mainThreadHandler = null;
 }

}

在activity中使用实例:

import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import android.widget.TextView;

public class PreLoaderActivity extends AppCompatActivity {

 private PreLoader preLoader;
 private TextView textView;

 @Override
 protected void onCreate(Bundle savedInstanceState) {
 preLoad();//启动预加载
 //进行页面布局加载及其它初始化工作
 super.onCreate(savedInstanceState);
 setContentView(R.layout.activity_main);
 textView = (TextView)findViewById(R.id.textView);
 //布局初始化完成
 preLoader.readyToGetData();
 }

 private void preLoad() {
 //预加载的任务
 preLoader = PreLoader.preLoad(new Runnable() {
  //将得到的请求结果展示到布局控件上
  @Override
  public void run() {
  //模拟网络请求耗时
  try {
   Thread.sleep(500);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  final String result = "result";
  //在UI线程执行的显示任务
  preLoader.performResultTask(new Runnable() {
   //将得到的请求结果展示到布局控件上
   @Override
   public void run() {
   textView.setText(result);
   }
  });
  }
 });
 }

 @Override
 protected void onDestroy() {
 super.onDestroy();
 //在onDestroy()中进行销毁
 preLoader.destroy();
 }
}

通过预加载,让一部分异步任务提前执行,可以用来提高整体速度。
以上都是以网络请求作为预加载的目的,它同时还可以用来预加载图片、预加载文件、读取数据库等;
除了预加载外,还可以用来作为多个任务并行,并全部执行完之后,再执行另一个任务对之前所有任务执行的结果进行处理。

总结:
在多线程开发时,经常会遇到以下情况:

任务A、任务B(甚至更多任务)是任务C的充要条件,为了提高效率,我们希望AB同时执行,当AB都完成之后,开始执行任务C。
这种情况下我们可以用这种方式来解决。

最后,源码下载地址

(0)

相关推荐

  • RxJava入门指南及其在Android开发中的使用示例

    RxJava的GitHub主页,部署部分就没什么好说的了~ https://github.com/ReactiveX/RxJava 基础 RxJava最核心的两个东西是Observables(被观察者,事件源)和Subscribers(观察者).Observables发出一系列事件,Subscribers处理这些事件.这里的事件可以是任何你感兴趣的东西(触摸事件,web接口调用返回的数据...) 一个Observable可以发出零个或者多个事件,知道结束或者出错.每发出一个事件,就会调用它的Su

  • android使用RxJava实现预加载

    在上一篇文章中介绍了使用非RxJava环境下,使用Handler机制SyncBarrier的特性实现预加载功能的方法. 在RxJava的环境下使用BehaviorSubject的特性来实现也是很方便的. BehaviorSubject内部会缓存消息流中最近的一个消息, 在后续有Subscriber订阅时,会直接将缓存的消息发送给Subscriber. RxPreLoader.java封装如下: import android.support.annotation.NonNull; import j

  • 使用RxJava中遇到的一些”坑“

    前言 大家越用RxJava,越觉得它好用,所以不知不觉地发现代码里到处都是RxJava的身影.然而,RxJava也不是银弹,其中仍然有很多问题需要解决.这里,我简单地总结一下自己遇到的一些"坑",内容上可能会比较松散. 一.考虑主线程的切换 RxJava中一个常用的使用方法是--在其他线程中做处理,然后切换到UI线程中去更新页面.其中,线程切换就是使用了observeOn().后台下载文件,前台显示下载进度就可以使用这种方式完成.然而,实践发现这其中有坑.如果文件比较大,而下载包的粒度

  • android非RxJava环境下使用Handler实现预加载

    在进行Android客户端界面开发时,我们常常会需要将从服务端获取的数据展示到页面布局上,由于数据显示到布局的前置条件是页面布局已初始化完成,否则会出现空指针异常,所以一般我们需要将网络请求放在布局初始化完成之后. 传统的页面加载流程是: 问题: 如果加载的UI布局比较复杂,或者初始化逻辑执行的时间比较多,那么网络请求开始执行的时间就比较晚,最终完成页面加载的时间就比较长. 如果页面初始化和网络加载能同时进行,等两者都执行结束后,再在布局上展示网络数据,这样我们就可以缩短整个页面的加载时间了.

  • Android 仿硅谷新闻下拉刷新/上拉加载更多

    1.添加加载更多布局 1_初始化和隐藏代码 在RefreshListView构造方法中调用 private void initFooterView(Context context) { View footerView = View.inflate(context, R.layout.refresh_listview_footer, null); //隐藏代码 footerView.measure(0, 0); int footerViewHeight = footerView.getMeasur

  • Android仿XListView支持下拉刷新和上划加载更多的自定义RecyclerView

    首先给大家展示下效果图,感觉还不错,请继续往下阅读: 下拉刷新:        上划加载        在项目更新的过程中,遇到了一个将XListView换成recyclerView的需求,而且更换完之后大体效果不能变,但是对于下拉刷新这样的效果,谷歌给出的解决方案是把RecyclerView放在一个SwipeRefreshLayout中,但是这样其实是拉下一个小圆形控件实现的,和XListView的header效果不同.在网上找了很多的别人代码,都没有实现我想要的效果,于是自己动手写了一个.

  • android使用PullToRefresh实现下拉刷新和上拉加载

    PullToRefresh是一套实现非常好的下拉刷新库,它支持: 1.ListView 2.ExpandableListView 3.GridView 4.WebView 等多种常用的需要刷新的View类型,而且使用起来也十分方便. demo实例下载 下载完成,将它导入到eclipse中,作为一个library导入到你的工程中就好了. 一.废话少说,下拉刷新Go. 1.在你的布局文件中加上你想用的View就好了,比如这儿我想用一个支持下拉 刷新的ExpandableListView <com.h

  • Android非异常情况下的Activity生命周期分析

    Activity非异常情况下的生命周期是指,用户正常参与UI交互的情况下,Activity所经过的生命周期的改变:一般情况下,Activity会经过以下几个生命周期. 1.OnCreate(): 表示Activity正在创建,这个是生命周期的第一个方法,该方法只调用一次,在这个方法中,一般做变量初始化的操作,例如绑定一个Button控件的Id等. 2.onRestart(): 表示Activity正在重新启动,一般情况下,如果最前面的Activity从不可见状态变为可见状态时,onRestart

  • RestTemplate在Spring或非Spring环境下使用精讲

    目录 一.什么是RestTemplate? 二.非Spring环境下使用RestTemplate 三.Spring环境下使用RestTemplate 一.什么是 RestTemplate? RestTemplate是执行HTTP请求的同步阻塞式的客户端,它在HTTP客户端库(例如JDK HttpURLConnection,Apache HttpComponents,okHttp等)基础封装了更加简单易用的模板方法API.也就是说RestTemplate是一个封装,底层的实现还是java应用开发中

  • Android下拉刷新上拉加载控件(适用于所有View)

    前面写过一篇关于下拉刷新控件的文章下拉刷新控件终结者:PullToRefreshLayout,后来看到好多人还有上拉加载更多的需求,于是就在前面下拉刷新控件的基础上进行了改进,加了上拉加载的功能.不仅如此,我已经把它改成了对所有View都通用!可以随心所欲使用这两个功能~~ 我做了一个大集合的demo,实现了ListView.GridView.ExpandableListView.ScrollView.WebView.ImageView.TextView的下拉刷新和上拉加载.后面会提供demo的

  • Android中使用RecyclerView实现下拉刷新和上拉加载

    推荐阅读:使用RecyclerView添加Header和Footer的方法                       RecyclerView的使用之HelloWorld RecyclerView 是Android L版本中新添加的一个用来取代ListView的SDK,它的灵活性与可替代性比listview更好.本文给大家介绍如何为RecyclerView添加下拉刷新和上拉加载,过去在ListView当中添加下拉刷新和上拉加载是非常方便的利用addHeaderView和addFooterVie

  • Android自定义下拉刷新上拉加载

    本文实例为大家分享了Android自定义下拉刷新上拉加载的具体实现步骤,供大家参考,具体内容如下 实现的方式是SwipeRefreshLayout + RecyclerView 的VIewType 首先看效果: 总的思路: 布局文件 <android.support.v4.widget.SwipeRefreshLayout android:layout_marginTop="?attr/actionBarSize" android:id="@+id/one_refres

随机推荐