Android 开发精要系列文章

HandlerThread的开发精要

2016-12-02  本文已影响34人  ahking17
为什么要使用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.---------------

上一篇下一篇

猜你喜欢

热点阅读