当前位置:操作系统 > 安卓/Android >>

Android中的MessageHandler机制一

 

总体思想就是两个(多个)线程共享一块存储区域,它们并发地操作这块内存。

 

下面是我自己初步写的模拟程序,有需要程序者可以联系我QQ402320131哈~:

 

这里仅贴上Hander, HandlerThread, Looper2

 

package com.zte.liu;

 

public class Handler {

 

 private Looper2 looper = null;

 

 public Handler(Looper2 looper){

  this.looper = looper;

 }

 

 public Message obtainMessage(){

  return new Message(this);

 }

 

 public Message obtainMessage(int id){

  return new Message(id, this);

 }

 

 public void dispatchMsg(Message msg){

  handleMessage(msg);

 }

 

 public Looper2 getLooper(){

  return looper;

 }

 

 public void handleMessage(Message msg){//钩子函数

  System.out.println(msg.getId());

 }

}

 

 

 

 

public class HandlerThread implements Runnable{

 

 public void run(){

  Looper2.prepare();

  Looper2.loop();

 }

 

}

 

 

 

 

 

package com.zte.liu;

 

public class Looper2 {

 

 private static Looper2 looper = null;

 private MessageQueue<Message> mQueue;

 private Looper2(){

  mQueue = new MessageQueue();

 }

 

 public static void prepare(){

  if(looper == null){

   looper = new Looper2();

  } www.zzzyk.com

 }

 

 public static Looper2 myLooper(){

  prepare();

  return looper;

 }

 

 public MessageQueue<Message> getQueue(){

  return mQueue;

 }

 

 public static final void loop(){

  System.out.println("loop begin...");

  Looper2 looper = myLooper();

  MessageQueue<Message> queue = looper.mQueue;

  if(looper == null) {

   return;

  }

  while(true){

   System.out.println("----queue size ="+queue.size());

   try {

    Thread.sleep(1000);

   } catch (InterruptedException e) {

    e.printStackTrace();

   }

   Message msg = (Message)queue.next();

   if(msg != null){

    if(msg.getHandler() == null)return;

    else{

     msg.getHandler().dispatchMsg(msg);

     Message.recycle(msg);

    }

   }

  }

 }

}

摘自:liuyangsyouxiang的专栏

补充:移动开发 , Android ,
CopyRight © 2022 站长资源库 编程知识问答 zzzyk.com All Rights Reserved
部分文章来自网络,