Android非UI线程之间通信

前言

一提到android消息通信，相信你第一反应就是android的Handler机制。一般而言都是一个线程对应一个handler，handler内部有一个Looper和MessageQueue。android的设计是给我们提供Handler来操作，而不用关心Message队列的处理。网上好多文章都是讲如何和UI线程通信，我在想，两个普通的Thread之间能通过handler通信吗？如果行，我是不是可以借鉴handler的这种机制去实现Java里普通的线程间通信，这样能够避免synchronized和lock的使用？

先不想着如何实现Java的线程间通信，先把handler的关于普通线程通信来实现一下，写了demo，很简单，就一个MainActivity，几个按钮

界面和一个简单的类代码

ui.png

public class MainActivity extends Activity implements View.OnClickListener{
private Button btn_thread1,btn_thread2;
private Button send1to2,sendto1,sendto2;
private boolean sendMsgThread1ToThread2=false;

private Handler uiHandler = new Handler(Looper.myLooper(), new Handler.Callback() {
    @Override
    public boolean handleMessage(Message message) {
        Log.d("主线程收到消息", message.what + "");
        if (message.what == 1){
            btn_thread1.setText("线程1已启动");
            btn_thread1.setClickable(false);
        }else if (message.what ==2){
            btn_thread2.setText("线程2已启动");
            btn_thread2.setClickable(false);
        }
        return true;
    }
});

@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.content_main);
    btn_thread1 = (Button)findViewById(R.id.btn_thread1);
    btn_thread2 = (Button)findViewById(R.id.btn_thread2);

    sendto1 = (Button)findViewById(R.id.sendto1);
    sendto2 = (Button)findViewById(R.id.sendto2);
    send1to2 = (Button)findViewById(R.id.send1to2);

    btn_thread1.setOnClickListener(this);
    btn_thread2.setOnClickListener(this);
    sendto1.setOnClickListener(this);
    sendto2.setOnClickListener(this);
    send1to2.setOnClickListener(this);
}

Handler subThread1Handler;
Handler subThread2Handler;
@Override
public void onClick(View view) {
    switch (view.getId()) {
        case R.id.btn_thread1:
            new Thread(new Runnable() {
                @Override
                public void run() {
                    Looper.prepare();

                    subThread1Handler = new Handler(Looper.myLooper(), new Handler.Callback() {
                        @Override
                        public boolean handleMessage(Message message) {
                            Log.d("线程1收到消息", message.what + "");
                            return true;
                        }
                    });

                    uiHandler.sendMessage(uiHandler.obtainMessage(1));
                    Looper.loop();
                }
            }).start();
            break;
        case R.id.btn_thread2:
            new Thread(new Runnable() {
                @Override
                public void run() {
                    Looper.prepare();

                    subThread2Handler = new Handler(Looper.myLooper(), new Handler.Callback() {
                        @Override
                        public boolean handleMessage(Message message) {
                            Log.d("线程2收到消息", message.what + "");
                            return true;
                        }
                    });

                    uiHandler.sendMessage(uiHandler.obtainMessage(2));
                    //线程2发送到线程1
                    subThread1Handler.sendMessage(subThread1Handler.obtainMessage(102));
                    Looper.loop();
                }
            }).start();
            break;
        case R.id.sendto1:
            //在主线程调用下面一行代码,所以是主线程发送到线程1
            subThread1Handler.sendMessage(subThread1Handler.obtainMessage(111));
            break;
        case R.id.sendto2:
            //在主线程调用下面一行代码,所以是主线程发送到线程2
            subThread2Handler.sendMessage(subThread2Handler.obtainMessage(222));
            break;
        case R.id.send1to2:
            //线程2发送到线程1
            break;
    }
}}

以上就是所有代码了，注释的也比较清楚，哈哈 ……-

1.ui线程如何发送消息给普通线程？

根据handler的用法，要发送消息到线程，就要往那个线程的消息队列里添加消息，所以调用handler的sendMessage方法，实际上它的sendMessage方法的底层实现就是MessageQueue添加了消息。注意这一点，同理，主线程往thread2发送消息也是一样，用subThread2Handler调用sendMessage即可。

2.普通线程如何发送消息给普通线程？

本来想在case R.id.send1to2: 代码里用一个变量控制，但是发现Loop.loop调用后线程就处于阻塞状态了（源码里调用了next方法），所以用while或者for期望用死循环也不管用。干脆就在thread2里调用subThread1Handler的sendMessage方法把。通过log可以看到，所有的日志均能正常打印。