HandlerThread的开发精要
为什么要使用HandlerThread
开发中, 经常使用 new Thread(new Runnable { ... }).start()这样的方式,
去执行一个访问网络或是IO这样的耗时操作. 但如果程序频繁的new Thread去创建线程, 就会带来不小的性能开销.
我们知道可以使用Android的handler去sendMessage, 然后在handler的handleMessage中去处理这个message, 使用起来非常的方便,
但有一点, 这里的handleMessage执行在UI线程, 不能在里面执行耗时操作.
如果想使用android这样的sendMessage和handleMessage这样的形式去发送和处理消息, 又不想让消息的处理执行在UI线程, 在这种情况下,
可以使用HandlerThread这个类.
HandlerThread的典型用法
private static final int MSG_QUERY_DATA = 4;
private static class WorkerThreadHandler extends Handler {
final WeakReference<ContentResolver> mResolver;
public WorkerThreadHandler(Looper looper, ContentResolver resolver) {
super(looper);
mResolver = new WeakReference<ContentResolver>(resolver);
}
@Override
public void handleMessage(Message msg) {
final ContentResolver resolver = mResolver.get();
if (resolver == null) return;
switch (msg.what) {
case MSG_QUERY_DATA:
//访问数据库的耗时操作
Cursor cursor;
cursor = resolver.query(SavePages.CONTENT_URI,
SavePages.ProjectionSavePages, null, null, SavePages.DATE_CREATED + " desc");
WebPageSaveInfo info = WebPageSaveInfo.createWebPageByCursor(cursor);
break;
default:
break;
}
}
}
HandlerThread thread = new HandlerThread("AsyncQueryWorker");
thread.start();
Looper looper = thread.getLooper();
//这个handler对象就是通过HandlerThread的looper创建出来的
WorkerThreadHandler mWorkerThreadHandler = new WorkerThreadHandler(looper, resolver);
//提供给外界的API
public void queryData() {
Message queryMsg = mWorkerThreadHandler.obtainMessage(MSG_QUERY_DATA, this);
mWorkerThreadHandler.sendMessage(queryMsg);
}
在上面的代码中, 如果looper的获取采用如下的代码:
Looper looper = Looper.getMainLooper();
//由UI线程的looper去创建出一个handler的话
WorkerThreadHandler mWorkerThreadHandler = new WorkerThreadHandler(looper, resolver);
那么上面handleMessage() 查询数据库的代码就会运行在UI线程.
HandlerThread的本质
本质就是一个特殊的Thread, 外界start()它后, 在它的run()中创建出一个looper, 并进入消息循环.
外界通过getLooper()把它的looper拿到后, 使用这个looper创建出handler, 用以发送消息和处理消息.
这样处理消息的代码就执行在了worker thread中了.
public class HandlerThread extends Thread {
@Override
public void run() {
mTid = Process.myTid();
Looper.prepare();
synchronized (this) {
mLooper = Looper.myLooper();
notifyAll();
}
Process.setThreadPriority(mPriority);
onLooperPrepared();
Looper.loop(); //线程block在这里.
mTid = -1;
}
public Looper getLooper() {
return mLooper;
}
}
本质:
它是个特殊的Thread, 自己创建了一个looper并提供给外部, 外界可以由此创建出一个handler出来. 通过handler.sendMessage(msg)或是handler.post(runnable)这样的形式发送任务给这个worker thread去执行.
项目中实际使用HandlerThread的位置
保存网页功能, 对数据库的操作, 都是通过HandlerThread去完成的.
通过handler向worker thread发送消息执行对数据库的操作, 这个worker thread一直在运行,持续等待新消息的到来并进行处理.
-----DONE.---------------