Android之HandlerThread

HandlerThread详解

1　HandlerThread基本原理

　　HandlerThread继承自Thread，它是一种可以使用Handler的Thread。它的实现很简单，就是在run方法中通过Looper.prepare()来创建消息队列，并通过Looper.loop()来开启消息循环。这样，我们就可以直接在HandlerThread中创建Handler了。HandlerThread的run方法如下所示：

public void run() {
    mTid = Process.myTid();
    Looper.prepare();
    synchronized (this) {
        mLooper = Looper.myLooper();
        notifyAll();
    }
    Process.setThreadPriority(mPriority);
    onLooperPrepared();
    Looper.loop();
    mTid = -1;
}

　　既然HandlerThread中已经有了消息循环，那么我们就可以在HandlerThread类或其子类中直接创建Handler对象，但是我们要记住一点：如果我们需要创建与该HandlerThread线程相关联的Handler的话，我们要使用Handler(Looper looper)构造方法，这样我们所创建的Handler对象才会与当前线程的消息循环相关联。在HandlerThread中，我们可以通过getLooper()方法获得Looper实例。

　　从HandlerThread的实现上来看，它和普通Thread有显著不同，普通Thread主要在run方法中执行耗时任务，而HandlerThread在内部创建了消息队列，外界需要通过Handler的消息方式来通知HandlerThread执行一个具体任务。通常，一个普通的Thread线程也可以成为Looper线程，我们只需要为其创建消息队列并开启消息循环即可。看如下实现代码：

class LooperThread extends Thread {
  public Handler mHandler;

  public void run() {
      Looper.prepare();

      mHandler = new Handler() {
          public void handleMessage(Message msg) {
              // process incoming messages here
          }
      };

      Looper.loop();
  }
}

我们可以根据不同应用场景选择不同的实现方式，不过既然Android已经提供了HandlerThread类，那我们在开发过程中可能会更倾向于使用该类完成耗时操作。

2　示例程序

　　我们将通过一个简单示例程序来说明HandlerThread的用法。本示例程序中，我们向HandlerThread发送消息，然后HandlerThread返回该消息并显示到TextView上，在这个过程中我们通过sleep来模拟耗时操作。我们将创建一个继承自HandlerThread的类：CustomHandlerThread，

public class CustomHandlerThread extends HandlerThread {
    private static final String TAG = "CustomHandlerThread";
    private static final int MSG_WHAT = 0x11;
    private Handler mResponseHandler;
    private Handler mHandler;
    private Callback mCallback;
    public CustomHandlerThread(Handler responseHandler, Callback callback){
        super(TAG);
        mHandler = new Handler();
        mResponseHandler = responseHandler;
        mCallback = callback;
    }

    public void enqueTask(String str, TextView textView){
        Log.i(TAG, "receive a str: " + str);
        mHandler.obtainMessage(MSG_WHAT, str).sendToTarget();
    }
    public void prepareHandler(){
        mHandler = new Handler(getLooper()){
            @Override
            public void handleMessage(final Message msg) {
                try{
                    TimeUnit.SECONDS.sleep(2);
                    final String result = (String)msg.obj;
                    mResponseHandler.post(new Runnable() {
                        @Override
                        public void run() {
                            mCallback.onResult(result);
                        }
                    });
                }catch (InterruptedException ie){
                    ie.printStackTrace();
                }
            }
        };
    }

    public interface Callback{
        public void onResult(String result);
    }
    public void removeMsg(){
        mHandler.removeMessages(MSG_WHAT);
    }

}

　　我们先看enqueTask方法，该方法很简单，我们仅用它来接收从外部传来的参数（准确的说是消息内容），并且通过当前线程的Handler将消息发送到当前线程消息队列中，对该消息的处理是在prepareHandler()方法中完成的。在prepareHandler方法中，我们创建Handler实例，并且与当前线程的消息队列相关联，这通过Handler(Looper looper)构造方法完成。mResponseHandler.post方法会将Runnable对象添加到主线程的消息队列，该Runnable对象将会在该mResponseHandler所属的线程中执行，由于mResponseHandler是从主线程传过来的（稍后我们会看到具体实现），因此Runnable将会运行在主线程中。run方法中我们通过回调接口来传递结果。下面我们看下MainActivity中的处理：

public class MainActivity extends Activity implements CustomHandlerThread.Callback{
    private TextView mTextView;

    private CustomHandlerThread mCustomHandlerThread;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        mTextView = (TextView)findViewById(R.id.textView);

        mCustomHandlerThread = new CustomHandlerThread(new Handler(), this);
        mCustomHandlerThread.start();
        mCustomHandlerThread.prepareHandler();
        for(int i = 0; i < 10; i++){
            mCustomHandlerThread.enqueTask("string"+i);
        }
    }

    @Override
    public void onResult(String result) {
        mTextView.setText(result);
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        mCustomHandlerThread.removeMsg();
        mCustomHandlerThread.quit();
    }
}

上面代码很简单，我们创建CustomHandlerThread并传入Handler对象，该Handler对象是在主线程中创建的，因此与主线程消息队列相关联，创建HandlerThread对象后必须要调用start方法，此外，在调用enqueTask之前必须先调用prepareHandler方法，以免导致空指针异常（Handler还没创建？怎么能向消息队列发送消息呢？）。最后要注意的是，当Activity退出时，我们一定要通过quit方法结束HandlerThread的执行。