HandlerThread 使用

在Android中，主线程和子线程通信，最简单最直接的方式就是使用Handler和Message，在子线程中使用 在主线程中创建的 Handler对象发送一个msg，就可以把子线程的消息发送到主线程中进行操作，这个在平常开发中很常见。
现在来想另外一种使用场景，主线程往子线程里，发送一个消息，让子线程来做不同的操作。
其实也可以通过Handler 和Msg 来操作。
<b>来模拟一个例子 经理打电话让司机接人的例子</b>。
经理打电话相当于在主线程发消息，司机在子线程完成接人的功能，然后反馈给经理（主线程）
来看代码

public class ThreadHandlerAc extends BaseActivity {

    private Button mButton;
    //经理的handler
    private Handler mMangerHandler;
    //司机的handler
    private Handler mDriverHandler;

    private EditText mLog_tv;

    @Override
    protected void initView() {
        setContentView(R.layout.ac_test);
        mButton = (Button) findViewById(R.id.ac_test_bt);
        mLog_tv=(EditText)findViewById(R.id.ac_test_log);

        driver.start();//司机开始等待
        mButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                //打电话给司机
                managerCallDriver("老总");

            }
        });

            mMangerHandler = new Handler() {
                @Override
                public void handleMessage(Message msg) {
                    super.handleMessage(msg);
                    log("经理收到接到人消息了 , 发生在 " + Thread.currentThread().getName());
                }
            };


    }

    private void log(final String log){
       runOnUiThread(new Runnable() {
           @Override
           public void run() {
               mLog_tv.setText(mLog_tv.getText() + "\n" + log) ;
           };
       });

    }

    //通知司机去接人
    private void managerCallDriver(String name) {
        log("经理打电话给司机去接"+name  + "发生在 " + Thread.currentThread().getName()+"线程");
        Message managerMsg = new Message();
        managerMsg.obj = name;
        mDriverHandler.sendMessage(managerMsg);
    }


    Thread driver = new Thread("driver") {
        @Override
        public void run() {
            super.run();
            //创建looper
            Looper.prepare();
            //从ThreadLoacl中回去looper
            mDriverHandler = new Handler(Looper.myLooper()) {
                @Override
                public void handleMessage(Message msg) {
                    super.handleMessage(msg);
                    try {
                        Thread.sleep(200);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    log("司机收到消息去接" + msg.obj + "发生在 " + Thread.currentThread().getName()+"线程");
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    log("司机接到人了，通知经理，发生在" + Thread.currentThread().getName()+"线程");

                    Message dreiverMsg = new Message();
                    dreiverMsg.obj = "经理，我接到人了";
                    dreiverMsg.what = 1;
                    mMangerHandler.sendMessage(dreiverMsg);
                }
            };
            //loop循环会让这个线程一直不会 停
            Looper.loop();

        }
    };


}


 

执行的结果

执行结果

注意代码Thread里run方法，需要自己去得到一个looper对象，需要自己去开启loop循环，而且，loop会一直循环，也就说这个线程一直开启，这样会导致Activity 无法回收，还得自己去结束线程，这样太麻烦了，其实可以利用Android 提供的ThreadHanlder类，同样可以完成，而且还不需要管理里looper，并且提供了结束线程的方法。
代码

public class ThreadHandlerAc extends BaseActivity {

    private Button mButton;
    //经理的handler
    private Handler mMangerHandler;
    //司机的handler
    private Handler mDriverHandler;

    private EditText mLog_tv;

    private HandlerThread driver;

    @Override
    protected void initView() {
        setContentView(R.layout.ac_test);
        mButton = (Button) findViewById(R.id.ac_test_bt);
        mLog_tv = (EditText) findViewById(R.id.ac_test_log);
        driver = new HandlerThread("driver");
        driver.start();//司机开始等待
        mDriverHandler = new Handler(driver.getLooper() ) {
            @Override
            public void handleMessage(Message msg) {
                super.handleMessage(msg);
                try {
                    Thread.sleep(200);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                log("司机收到消息去接" + msg.obj + "发生在 " + Thread.currentThread().getName() + "线程");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                log("司机接到人了，通知经理，发生在" + Thread.currentThread().getName() + "线程");
                Message dreiverMsg = new Message();
                dreiverMsg.obj = "经理，我接到人了";
                dreiverMsg.what = 1;
                mMangerHandler.sendMessage(dreiverMsg);
            }
        };

        mButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                //打电话给司机
                managerCallDriver("老总");

            }
        });

        mMangerHandler = new Handler() {
            @Override
            public void handleMessage(Message msg) {
                super.handleMessage(msg);
                log("经理收到接到人消息了 , 发生在 " + Thread.currentThread().getName());
            }
        };
    }

    private void log(final String log) {
        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                mLog_tv.setText(mLog_tv.getText() + "\n" + log);
            }

            ;
        });

    }

    //通知司机去接人
    private void managerCallDriver(String name) {
        log("经理打电话给司机去接" + name + "发生在 " + Thread.currentThread().getName() + "线程");
        Message managerMsg = new Message();
        managerMsg.obj = name;
        mDriverHandler.sendMessage(managerMsg);
    }

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

同样是完成了功能，还不需要提供looper的管理，并且有直接退出线程方法，是不是方便很多。
（如果博客有错误的地方，欢迎留言指正）。