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.2cto.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的专栏
相关新闻>>
- 发表评论
-
- 最新评论 更多>>
