当前位置:首页 > 芯闻号 > 充电吧
[导读]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出色的完成了任务。

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

9月2日消息,不造车的华为或将催生出更大的独角兽公司,随着阿维塔和赛力斯的入局,华为引望愈发显得引人瞩目。

关键字: 阿维塔 塞力斯 华为

加利福尼亚州圣克拉拉县2024年8月30日 /美通社/ -- 数字化转型技术解决方案公司Trianz今天宣布,该公司与Amazon Web Services (AWS)签订了...

关键字: AWS AN BSP 数字化

伦敦2024年8月29日 /美通社/ -- 英国汽车技术公司SODA.Auto推出其旗舰产品SODA V,这是全球首款涵盖汽车工程师从创意到认证的所有需求的工具,可用于创建软件定义汽车。 SODA V工具的开发耗时1.5...

关键字: 汽车 人工智能 智能驱动 BSP

北京2024年8月28日 /美通社/ -- 越来越多用户希望企业业务能7×24不间断运行,同时企业却面临越来越多业务中断的风险,如企业系统复杂性的增加,频繁的功能更新和发布等。如何确保业务连续性,提升韧性,成...

关键字: 亚马逊 解密 控制平面 BSP

8月30日消息,据媒体报道,腾讯和网易近期正在缩减他们对日本游戏市场的投资。

关键字: 腾讯 编码器 CPU

8月28日消息,今天上午,2024中国国际大数据产业博览会开幕式在贵阳举行,华为董事、质量流程IT总裁陶景文发表了演讲。

关键字: 华为 12nm EDA 半导体

8月28日消息,在2024中国国际大数据产业博览会上,华为常务董事、华为云CEO张平安发表演讲称,数字世界的话语权最终是由生态的繁荣决定的。

关键字: 华为 12nm 手机 卫星通信

要点: 有效应对环境变化,经营业绩稳中有升 落实提质增效举措,毛利润率延续升势 战略布局成效显著,战新业务引领增长 以科技创新为引领,提升企业核心竞争力 坚持高质量发展策略,塑强核心竞争优势...

关键字: 通信 BSP 电信运营商 数字经济

北京2024年8月27日 /美通社/ -- 8月21日,由中央广播电视总台与中国电影电视技术学会联合牵头组建的NVI技术创新联盟在BIRTV2024超高清全产业链发展研讨会上宣布正式成立。 活动现场 NVI技术创新联...

关键字: VI 传输协议 音频 BSP

北京2024年8月27日 /美通社/ -- 在8月23日举办的2024年长三角生态绿色一体化发展示范区联合招商会上,软通动力信息技术(集团)股份有限公司(以下简称"软通动力")与长三角投资(上海)有限...

关键字: BSP 信息技术
关闭
关闭