赞
踩
keyword:Android 使用handler实现线程间发送消息 (主线程 与 子线程之间)、(子线程 与 子线程之间)
相信大家平时都有使用到异步线程往主线程(UI线程)发送消息的情况。
本文主要研究Handler的消息发送。
包含主线程往子线程发送消息,子线程之间互相发送消息。
一、主线程向子线程发送消息。
实现过程比較简单:
主线程发送消息到异步线程。异步线程接收到消息后在再发送一条消息给主线程。
1. 初始化主线程的Handler,用来接收子线程的消息。
2. 启动异步线程。在异步线程中创建Looper,并初始化一个异步线程的Handler。
3. 主线程获取异步线程的Handler(这里涉及到线程间同步的知识)。并向异步线程发送消息。
4. 异步线程Handler接收到消息以后,获取主线程的Handler,并向主线程发送消息。
5. 主线程收到异步线程发来的消息。
注:
1. 这里说的主线程Handler或者异步线程Handler,指的是绑定在相应线程消息队列上的一个Handler对象而已,在Handler的构造函数中传入相应线程的Looper对象就可以。
2. 为什么要使用线程锁来处理,是由于异步线程启动不是实时的。主线程获取异步线程的Handler时有可能为空,假设为空,须要等待异步线程先初始化Handler。
上代码:
packagecom.example.chen.myapplication;importandroid.app.Activity;importandroid.os.Bundle;importandroid.os.Handler;importandroid.os.Looper;importandroid.os.Message;importandroid.util.Log;/*** 用Handler測试主线程往子线程发送消息*@authorchen*/public classHandlerSimpleActivity extendsActivity {
privateHandler mainHandler;@Overrideprotected voidonCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);// 启动异步线程finalAsyncThread asyncThread = newAsyncThread();asyncThread.start();// 初始化主线程的HandlermainHandler= newHandler(Looper.myLooper(), newHandler.Callback() {
@Overridepublic booleanhandleMessage(Message msg) {
// 主线程收到消息Log.e(HandlerSimpleActivity.class.getSimpleName(),"MainHandler Receiver Message curThread = "+ Thread.currentThread().getName());return false;}
});// 获取异步线程的HandlerHandler handler = asyncThread.getHandler();if(handler != null) {
Log.e(HandlerSimpleActivity.class.getSimpleName(),"MainThread Send Message curThread = "+ Thread.currentThread().getName());// 向异步线程发送消息handler.sendEmptyMessage(0);}
}
/*** 异步线程*/private classAsyncThread extendsThread {
privateHandler handler;@Overridepublic voidrun() {
super.run();Log.e(HandlerSimpleActivity.class.getSimpleName(),"AsyncThread Start curThread = "+ Thread.currentThread().getName());Looper.prepare();// 初始化异步线程的消息循环队列if(handler== null) {
synchronized(AsyncThread.class) { // 线程间安全// 为异步线程的消息循环队列新增一个Handlerhandler= newHandler(Looper.myLooper(), newHandler.Callback() {
@Overridepublic booleanhandleMessage(Message msg) {
// 异步线程收到消息Log.e(HandlerSimpleActivity.class.getSimpleName(),"AsyncHandler Receiver Message curThread = "+ Thread.currentThread().getName());// 异步线程发送消息到主线程Log.e(HandlerSimpleActivity.class.getSimpleName(),"AsyncThread Send Message curThread = "+ Thread.currentThread().getName());mainHandler.sendEmptyMessage(0);return false;}
});// 异步线程Handler初始化完成Log.e(HandlerSimpleActivity.class.getSimpleName(),"AsyncHandler Inited curThread = "+ Thread.currentThread().getName());// 释放锁AsyncThread.class.notifyAll();}
}
Looper.loop();}
/*** 获取异步线程的Handler*@return*/publicHandler getHandler() {
if(handler== null) {
synchronized(AsyncThread.class) { // 线程间安全if(handler== null) {
try{
// 获取异步线程的handler为空。释放锁,等待异步线程初始化完成。
Log.e(HandlerSimpleActivity.class.getSimpleName(),"getHandler wait curThread = "+ Thread.currentThread().getName());AsyncThread.class.wait();} catch(InterruptedException e) {
e.printStackTrace();}
// 异步线程Handler初始化完成。主线程继续Log.e(HandlerSimpleActivity.class.getSimpleName(),"getHandler notified curThread = "+ Thread.currentThread().getName());returnhandler;} else{
returnhandler;}
}
} else{
returnhandler;}
}
}
}
上结果截图:
二、子线程间使用Handler互相发送消息:
2015年7月26日19:47:31 等待下次更新(*^__^*) 嘻嘻……
2015年11月9日更新。线程间通信能够用HandlerThread。有兴趣的朋友能够看看源代码。就一个类。代码也不多,系统的API写的要健壮一些。
关于HandlerThread。大家能够阅读该片博客:
本人Android菜鸟,尽请指正!!
!
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。