下面我们会以android实例来展示对应的功能,程序界面于下:

程序代码如下,后面部分有代码说明:

                       1         package com.android.messageexample; 
2 import android.app.Activity;
3 import android.content.Context;
4 import android.graphics.Color;
5 import android.os.Bundle;
6 import android.os.Handler;
7 import android.os.Looper;
8 import android.os.Message;
9 import android.util.Log;
10 import android.view.View;
11 import android.view.View.OnClickListener;
12 import android.widget.Button;
13 import android.widget.LinearLayout;
14 import android.widget.TextView;
15 public class MessageExample extends Activity implements OnClickListener {
16 private final int WC = LinearLayout.LayoutParams.WRAP_CONTENT;
17 private final int FP = LinearLayout.LayoutParams.FILL_PARENT;
18 public TextView tv;
19 private EventHandler mHandler;
20 private Handler mOtherThreadHandler = null ;
21 private Button btn, btn2, btn3, btn4, btn5, btn6;
22 private NoLooperThread noLooerThread = null ;
23 private OwnLooperThread ownLooperThread = null ;
24 private ReceiveMessageThread receiveMessageThread = null ;
25 private Context context = null ;
26 private final String sTag = " MessageExample " ;
27 private boolean postRunnable = false ;
28
29 /* * Called when the activity is first created. */
30 @Override
31 public void onCreate(Bundle savedInstanceState) {
32 super.onCreate(savedInstanceState);
33 context = this .getApplicationContext();
34 LinearLayout layout = new LinearLayout( this );
35 layout.setOrientation(LinearLayout.VERTICAL);
36 btn = new Button( this );
37 btn.setId( 101 );
38 btn.setText( " message from main thread self " );
39 btn.setOnClickListener( this );
40 LinearLayout.LayoutParams param =
41 new LinearLayout.LayoutParams( 250 , 50 );
42 param.topMargin = 10 ;
43 layout.addView(btn, param);
44 btn2 = new Button( this );
45 btn2.setId( 102 );
46 btn2.setText( " message from other thread to main thread " );
47 btn2.setOnClickListener( this );
48 layout.addView(btn2, param);
49 btn3 = new Button( this );
50 btn3.setId( 103 );
51 btn3.setText( " message to other thread from itself " );
52 btn3.setOnClickListener( this );
53 layout.addView(btn3, param);
54 btn4 = new Button( this );
55 btn4.setId( 104 );
56 btn4.setText( " message with Runnable as callback from other thread to main thread " );
57 btn4.setOnClickListener( this );
58 layout.addView(btn4, param);
59 btn5 = new Button( this );
60 btn5.setId( 105 );
61 btn5.setText( " main thread's message to other thread " );
62 btn5.setOnClickListener( this );
63 layout.addView(btn5, param);
64 btn6 = new Button( this );
65 btn6.setId( 106 );
66 btn6.setText( " exit " );
67 btn6.setOnClickListener( this );
68 layout.addView(btn6, param);
69 tv = new TextView( this );
70 tv.setTextColor(Color.WHITE);
71 tv.setText( "" );
72 LinearLayout.LayoutParams param2 =
73 new LinearLayout.LayoutParams(FP, WC);
74 param2.topMargin = 10 ;
75 layout.addView(tv, param2);
76 setContentView(layout);
77
78 // 主线程要发送消息给other thread, 这里创建那个other thread
79 receiveMessageThread = new ReceiveMessageThread();
80 receiveMessageThread.start();
81 }
82
83 // implement the OnClickListener interface
84 @Override
85 public void onClick(View v) {
86 switch (v.getId()){
87 case 101 :
88 // 主线程发送消息给自己
89 Looper looper;
90 looper = Looper.myLooper(); // get the Main looper related with the main thread
91 // 如果不给任何参数的话会用当前线程对应的Looper(这里就是Main Looper)为Handler里面的成员mLooper赋值
92 mHandler = new EventHandler(looper);
93 // mHandler = new EventHandler();
94 // 清除整个MessageQueue里的消息
95 mHandler.removeMessages( 0 );
96 String obj = " This main thread's message and received by itself! " ;
97 // 得到Message对象
98 Message m = mHandler.obtainMessage( 1 , 1 , 1 , obj);
99 // 将Message对象送入到main thread的MessageQueue里面
100 mHandler.sendMessage(m);
101 break ;
102 case 102 :
103 // other线程发送消息给主线程
104 postRunnable = false ;
105 noLooerThread = new NoLooperThread();
106 noLooerThread.start();
107 break ;
108 case 103 :
109 // other thread获取它自己发送的消息
110 tv.setText( " please look at the error level log for other thread received message " );
111 ownLooperThread = new OwnLooperThread();
112 ownLooperThread.start();
113 break ;
114 case 104 :
115 // other thread通过Post Runnable方式发送消息给主线程
116 postRunnable = true ;
117 noLooerThread = new NoLooperThread();
118 noLooerThread.start();
119 break ;
120 case 105 :
121 // 主线程发送消息给other thread
122 if ( null != mOtherThreadHandler){
123 tv.setText( " please look at the error level log for other thread received message from main thread " );
124 String msgObj = " message from mainThread " ;
125 Message mainThreadMsg = mOtherThreadHandler.obtainMessage( 1 , 1 , 1 , msgObj);
126 mOtherThreadHandler.sendMessage(mainThreadMsg);
127 }
128 break ;
129 case 106 :
130 finish();
131 break ;
132 }
133 }
134 class EventHandler extends Handler
135 {
136 public EventHandler(Looper looper) {
137 super(looper);
138 }
139 public EventHandler() {
140 super();
141 }
142 public void handleMessage(Message msg) {
143 // 可以根据msg.what执行不同的处理,这里没有这么做
144 switch (msg.what){
145 case 1 :
146 tv.setText((String)msg.obj);
147 break ;
148 case 2 :
149 tv.setText((String)msg.obj);
150 noLooerThread.stop();
151 break ;
152 case 3 :
153 // 不能在非主线程的线程里面更新UI,所以这里通过Log打印收到的消息
154 Log.e(sTag, (String)msg.obj);
155 ownLooperThread.stop();
156 break ;
157 default :
158 // 不能在非主线程的线程里面更新UI,所以这里通过Log打印收到的消息
159 Log.e(sTag, (String)msg.obj);
160 break ;
161 }
162 }
163 }
164 // NoLooperThread
165 class NoLooperThread extends Thread{
166 private EventHandler mNoLooperThreadHandler;
167 public void run() {
168 Looper myLooper, mainLooper;
169 myLooper = Looper.myLooper();
170 mainLooper = Looper.getMainLooper(); // 这是一个static函数
171 String obj;
172 if (myLooper == null ){
173 mNoLooperThreadHandler = new EventHandler(mainLooper);
174 obj = " NoLooperThread has no looper and handleMessage function executed in main thread! " ;
175 }
176 else {
177 mNoLooperThreadHandler = new EventHandler(myLooper);
178 obj = " This is from NoLooperThread self and handleMessage function executed in NoLooperThread! " ;
179 }
180 mNoLooperThreadHandler.removeMessages( 0 );
181 if ( false == postRunnable){
182 // send message to main thread
183 Message m = mNoLooperThreadHandler.obtainMessage( 2 , 1 , 1 , obj);
184 mNoLooperThreadHandler.sendMessage(m);
185 Log.e(sTag, " NoLooperThread id: " + this .getId());
186 } else {
187 // 下面new出来的实现了Runnable接口的对象中run函数是在Main Thread中执行,不是在NoLooperThread中执行
188 // 注意Runnable是一个接口,它里面的run函数被执行时不会再新建一个线程
189 // 您可以在run上加断点然后在eclipse调试中看它在哪个线程中执行
190 mNoLooperThreadHandler.post( new Runnable(){
191 @Override
192 public void run() {
193 tv.setText( " update UI through handler post runnalbe mechanism! " );
194 noLooerThread.stop();
195 }
196 });
197 }
198 }
199 }
200
201 // OwnLooperThread has his own message queue by execute Looper.prepare();
202 class OwnLooperThread extends Thread{
203 private EventHandler mOwnLooperThreadHandler;
204 public void run() {
205 Looper.prepare();
206 Looper myLooper, mainLooper;
207 myLooper = Looper.myLooper();
208 mainLooper = Looper.getMainLooper(); // 这是一个static函数
209 String obj;
210 if (myLooper == null ){
211 mOwnLooperThreadHandler = new EventHandler(mainLooper);
212 obj = " OwnLooperThread has no looper and handleMessage function executed in main thread! " ;
213 }
214 else {
215 mOwnLooperThreadHandler = new EventHandler(myLooper);
216 obj = " This is from OwnLooperThread self and handleMessage function executed in NoLooperThread! " ;
217 }
218 mOwnLooperThreadHandler.removeMessages( 0 );
219 // 给自己发送消息
220 Message m = mOwnLooperThreadHandler.obtainMessage( 3 , 1 , 1 , obj);
221 mOwnLooperThreadHandler.sendMessage(m);
222 Looper.loop();
223 }
224 }
225
226 // ReceiveMessageThread has his own message queue by execute Looper.prepare();
227 class ReceiveMessageThread extends Thread{
228 public void run() {
229 Looper.prepare();
230 mOtherThreadHandler = new Handler(){
231 public void handleMessage(Message msg) {
232 Log.e(sTag, (String)msg.obj);
233 }
234 };
235 Looper.loop();
236 }
237 }
238
239 }
240

使用Looper.myLooper静态方法可以取得当前线程的Looper对象。
使用mHandler = new EevntHandler(Looper.myLooper()); 可建立用来处理当前线程的Handler对象;其中,EevntHandler是Handler的子类。
使用mHandler = new EevntHandler(Looper.getMainLooper()); 可建立用来处理main线程的Handler对象;其中,EevntHandler是Handler的子类。
主线程发送消息:
在onClick的case 101中创建一个继承自Handler的EventHandler对象,然后获取一个消息,然后通过EventHandler对象调用 sendMessage把消息发送到主线程的MessageQueue中。主线程由系统创建,系统会给它建立一个Looper对象和 MessageQueue,所以可以接收消息。这里只要根据主线程的Looper对象初始化EventHandler对象,就可以通过 EventHandler对象发送消息到主线程的消息队列中。
主线程处理消息:
这里是通过 EventHandler的handleMessage函数处理的,其中收到的Message对象中what值为一的消息就是发送给它的,然后把消息里面附带的字符串在TextView上显示出来。
其他线程发送消息(这里是说不使用Runnable作为callback的消息):
首先 postRunnable设为false,表示不通过Runnable方式进行消息相关的操作。然后启动线程noLooerThread, 然后以主线程的Looper对象为参数建立EventHandler的对象mNoLooperThreadHandler,然后获取一个Message并把一个字符串赋值给它的一个成员obj,然后通过mNoLooperThreadHandler把消息发送到主线程的MessageQueue中。
主线程处理消息:
这里是通过 EventHandler的handleMessage函数处理的,其中收到的Message对象中what值为二的消息就是上面发送给它的,然后把消息里面附带的字符串在TextView上显示出来。
其他线程发送消息:
其他非主线程建立后没有自己的Looper对象,所以也没有MessageQueue,需要给非主线程发送消息时需要建立MessageQueue以便接收消息。下面说明如何给自己建立MessageQueue和Looper对象。从OwnLooperThread的run函数中可以看见有一个 Looper.prepare()调用,这个就是用来建立非主线程的MessageQueue和Looper对象的。
所以这里的发送消息过程是建立线程mOwnLooperThread,然后线程建立自己的Looper和MessageQueue对象,然后根据上面建立的Looper对象建立对应的EventHandler对象mOwnLooperThreadHandler,然后由mOwnLooperThreadHandler建立消息并且发送到自己的MessageQueue里面。
其他线程处理接收的消息:
线程要接收消息需要在run函数中调用Looper.loop(),然后loop函数会从MessageQueue中取出消息交给对应的Handler对象 mOwnLooperThreadHandler处理,在mOwnLooperThreadHandler的handleMessage函数中会把 Message对象中what值为三的消息(上面发送的消息)在Log中打印出来,可以通过Logcat工具查看log。
其他线程发送消息(这里是说使用Runnable作为callback的消息):
首先 postRunnable设为true,表示通过Runnable方式进行消息相关的操作。然后启动线程noLooerThread, 然后以主线程的Looper对象为参数建立EventHandler的对象mNoLooperThreadHandler,然后获取一个Message并把一个字符串赋值给它的一个成员obj,然后通过mNoLooperThreadHandler把消息发送到主线程的MessageQueue中。
主线程处理消息:

主线程收到上面发送的Message后直接运行上面Runnable对象中的run函数进行相应的操作。run函数通过Log打印一个字符串,可以通过Logcat工具查看 log。
主线程发送消息:
这里首先要求线程receiveMessageThread运行(在onCreate函数中完成),并且准备好自己的 Looper和MessageQueue(这个通过ReceiveMessageThread中的run函数中的Looper.prepare()调用完成),然后根据建立的Looper对象初始化Handler对象mOtherThreadHandler。然后在onClick的case 105中由mOtherThreadHandler建立一个消息(消息中有一个字符串对象)并且发送到线程receiveMessageThread中的 MessageQueue中。
其他线程处理接收的消息:
线程要接收消息需要在run函数中调用Looper.loop(),然后loop函数会从MessageQueue中取出消息交给对应的Handler对象mOtherThreadHandler处理,在mOtherThreadHandler的handleMessage函数中会把Message对象中的字符串对象在Log中打印出来,可以通过Logcat工具查看log

更多相关文章

  1. android捕获全局异常处理,不闪退
  2. 注意:Android中Handler引起的内存泄露
  3. Android消息推送时刻
  4. 【从源码看Android】03Android(安卓)MessageQueue消息循环处理机
  5. 如何分析解决Android(安卓)ANR
  6. android中使用线程(比如修改textview的text)
  7. 史上最全!押题率90%的 Android(安卓)中高级工程师面试复习大纲及
  8. Android中UI线程与后台线程交互设计的5种方法
  9. 进程(一) 1.1 Android中异步处理大杀器——AsyncTask

随机推荐

  1. -Android各版本系统源代码下载
  2. android Http通信(访问web server)
  3. android开发常见问题
  4. 浅析:Android WebView 常见的九个问题
  5. Android中开源库EventBus使用详解
  6. Android(安卓)消息队列模型详解及实例
  7. 我的android 第二天 - 短信发送器
  8. Android中onInterceptTouchEvent与onTouc
  9. Android studio之build配置
  10. Android学习-五布局之相对布局