当前位置:首页 > 芯闻号 > 充电吧
[导读]Android没有全局的消息队列,Android的消息队列是和某个线程相关联在一起的。每个线程最多只有一个消息队列,消息的处理也是在这个线程中完成。也就是说,如果想在当前线程中使用消息模型,则必须构建

Android没有全局的消息队列,Android的消息队列是和某个线程相关联在一起的。每个线程最多只有一个消息队列,消息的处理也是在这个线程中完成。也就是说,如果想在当前线程中使用消息模型,则必须构建一个消息队列,消息机制的主要类是:Looper、Handler、MessageQueue、Message. 1、
public class Handler extends Object
java.lang.Object    ↳ android.os.Handler Class Overview

A Handler allows you to send and process Message and Runnable objects associated with a thread'sMessageQueue. Each Handler instance is associated with a single thread and that thread's message queue. When you create a new Handler, it is bound to the thread / message queue of the thread that is creating it -- from that point on, it will deliver messages and runnables to that message queue and execute them as they come out of the message queue.
 

 mHandler = new Handler(){
	public void handleMessage(Message msg){
//int android.os.Message.what
//User-defined message code so that the recipient can identify what this message is about.
switch(msg.what){
		 case UPDATE_TEXT:
		mTextView.setText("text changed");
		 break;
		default:
		 break;
		}
	                                }
		};



public final boolean sendMessage(Message msg)Added inAPI level 1

Pushes a message onto the end of the message queue after all pending messages before the current time. It will be received inhandleMessage(Message), in the thread attached to this handler.

Returns Returns true if the message was successfully placed in to the message queue. Returns false on failure, usually because the looper processing the message queue is exiting.

Message mMessage = Message.obtain(mHandler, UPDATE_TEXT);

//Pushes a message onto the end of the message queue after all pending messages before the current time. 
mHandler.sendMessage(mMessage);

Handler负责将Message发送至当前线程的MessageQueue中,处理消息。发送消息一般是使用Handler的sendMessage方法,发出的消息最终会传递到Handler的handleMessage()方法中。
public final class 2、 Looper extends Object
java.lang.Object    ↳ android.os.Looper Class Overview

Class used to run a message loop for a thread. Threads by default do not have a message loop associated with them; to create one, callprepare() in the thread that is to run the loop, and thenloop() to have it process messages until the loop is stopped.

Most interaction with a message loop is through the Handler class. 

Looper时时刻刻监视着MessageQueue,是每个线程中的MessageQueue管家,每个线程中只有一个Looper,调用其loop()方法就会进入到一个无限循环中,每当发现MessageQueue中存在一条消息,就会把它取出,送到Handler中的handleMessage()中。 public final class 3、
MessageQueue extends Object
java.lang.Object    ↳ android.os.MessageQueue 消息队列,每个线程中只会有一个MessageQueue。主要存放所有通过Handler发送的消息。

4、 public final class Message extends Object
implements Parcelable java.lang.Object    ↳ android.os.Message Class Overview

Defines a message containing a description and arbitrary data object that can be sent to aHandler. This object contains two extra int fields and an extra object field that allow you to not do allocations in many cases. 


//Message android.os.Message.obtain(Handler h, int what)
Message mMessage = Message.obtain(mHandler, UPDATE_TEXT);

Message是在线程之间传递消息,它可以在内部携带少量信息,如what字段、arg1、arg2来携带一些整型数据、obj携带Object对象,用于在不同线程间交换数据。

异步消息处理的整个流程:
首先需要在主线程中创建一个Handler对象,并重写handleMessage()方法; 然后,当子线程中需要UI操作时,就创建一个Message对象,并通过Handler将消息发送出去; 之后这条消息会被添加到MessageQueue队列中,等待被处理,期间Looper会一直尝试从MessageQueue中取出待处理消息,最后分发到Handler的handleMessage()方法中。由于Handler是在主线程中创建的,因此handleMessage()中的代码也会在主线程中处理。
MeloDev的Message游历:
Message
在边境X(子线程)服役的士兵Message慵懒的躺在一个人数为50(线程中最大数量)的军营(Message池)中。不料这时突然接到上司的obtain()命令,让它去首都(主线程)告诉中央领导一些神秘代码。小mMessage慌乱地整理下衣角和帽子,带上信封,准备出发。上司让士兵mMessage收拾完毕等待一个神秘人电话,并嘱咐他:到了首都之后,0是这次的暗号。

Message mMessage = Message.obtain();
Bundle bundle = new Bundle();
bundle.putString("key","这里一切安全");
mMessage.what = 0;
mMessage.obj = bundle;

通常会用obtain()方法创建Message,如果消息池中有Message则取出,没有则创建,这样防止对象重复创建,节省资源。 obtain()方法源码:

 /**
     * Return a new Message instance from the global pool. Allows us to
     * avoid allocating new objects in many cases.
     */
    public static Message obtain() {
        synchronized (sPoolSync) {
            if (sPool != null) {
                Message m = sPool;
                sPool = m.next;
                m.next = null;
                sPoolSize--;
                return m;
            }
        }
        return new Message();
    }


“铃铃铃……”,小mMessage接到一个店换,"我叫Handler,来此Activity大本营,是你这次任务的接收者,一会我会带你去首都的消息中心去报道。"

Handler:
来此Activity大本营的Handler部门是整个消息机制的核心部门,部门里有很多个Handler,这次协助小mMessage的叫mHandler.

 mHandler = new Handler(){
	public void handleMessage(Message msg){
//int android.os.Message.what
//User-defined message code so that the recipient can identify what this message is about.
				
				
			}
		};

Handler属于Activity,创建任何一个Handler都属于重写了Activity的Handler。

在Handler的构造中,默认完成了对当前线程Looper的绑定。

public Handler(Callback callback, boolean async) {
        if (FIND_POTENTIAL_LEAKS) {
            final Class klass = getClass();
            if ((klass.isAnonymousClass() || klass.isMemberClass() || klass.isLocalClass()) &&
                    (klass.getModifiers() & Modifier.STATIC) == 0) {
                Log.w(TAG, "The following Handler class should be static or leaks might occur: " +
                    klass.getCanonicalName());
            }
        }

        mLooper = Looper.myLooper();
        if (mLooper == null) {
            throw new RuntimeException(
                "Can't create handler inside thread that has not called Looper.prepare()");
        }
        mQueue = mLooper.mQueue;
        mCallback = callback;
        mAsynchronous = async;
    }


通过Looper.myLooper()方法获得当前线程保存的Looper实例,通过Looper.mQueue()获得MessageQueue实例, static Looper myLooper()Return the Looper object associated with the current thread. static MessageQueue myQueue()Return the MessageQueue object associated with the current thread. 在此时,mHandler实例与looper、messageQueue实例关联上了。
mHandler神情骄傲的对小mMessage说:我已经跟首都的消息中心打好了招呼,准备接收你了,现在有两种车“send”和“post”你想坐哪辆都可以,不过要根据你上司的命令选择对应的型号哦~
post、send: final boolean post(Runnable r)Causes the Runnable r to be added to the message queue. final boolean postAtFrontOfQueue(Runnable r)Posts a message to an object that implements Runnable. final boolean postAtTime(Runnable r,Object token, long uptimeMillis)Causes the Runnable r to be added to the message queue, to be run at a specific time given by. final boolean postAtTime(Runnable r, long uptimeMillis)Causes the Runnable r to be added to the message queue, to be run at a specific time given by. final boolean postDelayed(Runnable r, long delayMillis)Causes the Runnable r to be added to the message queue, to be run after the specified amount of time elapses final boolean sendEmptyMessage(int what)Sends a Message containing only the what value. final boolean sendEmptyMessageAtTime(int what, long uptimeMillis)Sends a Message containing only the what value, to be delivered at a specific time. final boolean sendEmptyMessageDelayed(int what, long delayMillis)Sends a Message containing only the what value, to be delivered after the specified amount of time elapses. final boolean sendMessage(Message msg)Pushes a message onto the end of the message queue after all pending messages before the current time. final boolean sendMessageAtFrontOfQueue(Message msg)Enqueue a message at the front of the message queue, to be processed on the next iteration of the message loop. boolean sendMessageAtTime(Message msg, long uptimeMillis)Enqueue a message into the message queue after all pending messages before the absolute time (in milliseconds). final boolean sendMessageDelayed(Message msg, long delayMillis)Enqueue a message into the message queue after all pending messages before (current time + delayMillis). String toString()
分析源码,post方法也是在使用send类在发送消息,除了sendMessageAtFrontOfQueue()外,其余send方法都经过层层包装走到sendMessageAtTime()中。 这时小mMessage和mHandler上了sendMessage的车,行驶在一条叫enqueueMessage的高速公路上进入MessageQueue。将Message按时间排序,放入MessageQueue中。其中mMessage.target = this,是保证每个发送Message的Handler也能处理这个Message。mHandler向小mMessage说,其实你的消息到时候也是我处理的,不过现在还不是时候,因为我很忙。
Looper
路上时间,mHandler为小mMessage热心介绍着MessageQueue和Looper。“在每个驻扎地(线程)中只有一个MessageQueue和一个Looper,他们两个是相爱相杀,同生共死的好朋友,Looper是个跑不死的邮差,一直负责取出MessageQueue中的Message”。 "不过通常只有首都(主线程)的Looper和MessageQueue是创建好的,其他地方需要我们人为创建"。 Looper提供prepare()方法来创建Looper。重复创建会抛出异常,也就是说每个线程只能有一个looper。

Looper.prepare();

static void prepareMainLooper()Initialize the current thread as a looper, marking it as an application's main looper.
Looper的构造方法中,创建了和他一一对应的MessageQueue

private Looper(boolean quitAllowed){
   mQueue = new MessageQueue(quitAllowed);
   mThread = Thread.currentThread();
}


在Android中ActivityThread的main方法是程序入口,主线程的Looper和MessageQueue就是在此刻创建。

mHandler和小mMessage来到了MessageQueue中,进入队列之前,门卫仔细给小mMessage贴上以下标签:“mHandler负责带入”、“处理时间为0ms”并告诉小mMessage一定要按时间顺序排队。进入队伍中,Looper正不辞辛劳的将一个个跟小mMessage一样的士兵带走。 public static void loop() Run the message queue in this thread. Be sure to callquit() to end the loop.   loop()方法有一个for死循环,不断调用queue.next()方法,在消息队列中取出Message。并在Message中取出target,这个target就是发送消息的mHandler调用它的dispatchMessage()方法。
首都的MessageQueue中心虽然message很多,但大家都按时间排着队,轮到mMessage了,Looper看了小mMessage的标签,对他说:“喔,又是mHandler带来的啊,那把你交给他处理了。”忐忑不安的小mMessage看到了一个熟悉的身影,mHandler,可能是接触太多Message,为了让mHandler想起自己,mMessage说出了上司教他的暗号0。

public void dispatchMessage(Message msg){
if(msg.callback != null){
handleCallback.handleMessage(msg);
}else{
if(mCallback != null){
if(mCallback.handleMessage(msg)){
return;}
}
handleMessage(msg);
}
}

dispatchMessage()方法:若mCallback不为空,则调用mCallback的handleMessage();否则,直接调用Handler的handleMessage()方法,并将消息对象作为参数传递过去。在handleMessage()方法中,小mMessage出色的完成了任务。

本站声明: 本文章由作者或相关机构授权发布,目的在于传递更多信息,并不代表本站赞同其观点,本站亦不保证或承诺内容真实性等。需要转载请联系该专栏作者,如若文章内容侵犯您的权益,请及时联系本站删除。
换一批
延伸阅读

罗德与施瓦茨与SmartViser携手开发了一种用于测试符合欧盟销售的智能手机和平板电脑的新Energy Efficiency Index(EEI)标签法规的解决方案。该解决方案的核心是R&S CMX500,这是...

关键字: 智能手机 Android iOS

(全球TMT2023年8月24日讯)2023年8月23日,时值实时3D引擎Unity在华设立合资公司Unity中国一周年之际,Unity中国正式推出Unity中国版引擎——团结引擎。Unity全球CEO John Ri...

关键字: UNITY CE Android 开发者

报告显示:全球电商 App 获客花费接近50亿美元 北京2023年8月23日 /美通社/ -- 全球营销衡量与体验管理平台 AppsFlyer 近日发布《2023 电商 App 营销现状报告》。尽管面临全球经...

关键字: APPS BSP iOS Android

数字机顶盒是一种数字技术下的多媒体娱乐中心,可以实现电视节目接收、播放、存储、网络应用等多种功能。随着科技的发展,数字机顶盒的设计方案也在不断进步和优化。本文将介绍数字机顶盒设计的几种实现方案。

关键字: 数字机顶盒 Android Linux

21ic 近日获悉,原小米 9 号创始员工李明在社交媒体平台公布了旗下首款产品乐天派桌面机器人,为全球首款 Android 桌面机器人,面向极客和发烧友的 AI + 机器人。据悉,李明两个月前宣布创业并进军 AI 领域,...

关键字: 小米 Android 桌面机器人 AI

尽管安装增长放缓,全球游戏 App 获客花费仍高达 267 亿美元 经济低迷导致 2023 游戏 App 营销优先考虑收入指标,用户增长次之 北京2023年3月9日 /美通社/ -- 今天,全球营销衡量与体验管理平台...

关键字: APPS iOS Android BSP

量子计算领域的新里程碑,来了! 谷歌科学家证明,通过增加量子比特的数量,就能降低量子计算的错误率。

关键字: 谷歌 Android Windows

「卫星通讯」正在被普及到每一台智能手机当中。普及的动机并非是消费市场的一个刚需,其实更像是将差异化的功能「抹平」成一个标配。时下,支持「卫星通讯」功能的智能手机只有苹果的 iPhone 14 系列与华为的 Mate 50...

关键字: 卫星通讯 Android 智能手机 iPhone

Android是Google开发的操作系统,支持多种指令集架构 (ISA),包括Arm和x86,多数使用Android的设备都采用Arm架构芯片组。新兴RISC-V架构是免费开放指令集架构,任何人都可用它设计芯片,且无需...

关键字: 谷歌 Android RISC-V架构

智能手机并非每年都取得重大进展,这导致越来越多的人将手机保留两年、三年或四年。不过,普通的 Android 手机能否在遇到问题之前使用那么久?

关键字: Android 安卓 谷歌 智能手机
关闭
关闭