Android主线程发消息给子线程

朴灿烈づ我的快乐病毒、 2022-06-16 12:38 158阅读 0赞

我们平时，是从子线程向主线程发消息，而主线程默认已经帮我们完成了Looper的操作，所以我们只需要简单的“创建一个Handler对象，然后一个线程发消息，另一个接收消息”……  
我们先说一下这个Looper是神马吧。  
它就像一个消息队列（MessageQueue）的管家（Looper），一个消息队列只有一个管家，并且管理者整个消息队列，而一个消息队列内可以容纳多个消息（Message），而工人（Handler）也可以有多个，管家派遣他们向消息队列中存储或取出消息后执行任务；

所以它们的个数如下：  
管家（Looper）: 1 个；  
消息队列（MessageQueue）：1 个；  
消息（Message）：可以多个；  
工人（Handler）：可以多个；

对Looper的Android源码整理了一下，可以得到如下的内容：

//ThreadLocal可以理解为一个存储Looper的列表；
    ThreadLocal<Looper> sThreadLocal = new ThreadLocal<Looper>();
    //Looper的构造器
    private Looper(boolean quitAllowed) {
            mQueue = new MessageQueue(quitAllowed);
            mThread = Thread.currentThread();
        }
    
    1.Looper.prepare()完成了如下操作：
    sThreadLocal.set(new Looper(quitAllowed));
    
    2.Looper.loop()完成了如下操作：
    Looper me = sThreadLocal.get();
    
    MessageQueue queue = me.mQueue;
    
    ……
    //不断循环分发消息
    for (;;) {
        Message msg = queue.next(); 
        ……
        msg.target.dispatchMessage(msg);
    
            //dispatchMessage(msg)方法执行如下内容：
            handler.handleMessage(msg);//handler执行handleMessage(msg)中的代码；
        ……
    };

下面是主线程和子线程之间通信例子：

public class MainActivity extends Activity { 
        private SonThread sonThread = null;//子线程
        private static final String TAG = "%%%";
    
        @Override
        protected void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.activity_main);
            sonThread = new SonThread();
            sonThread.start();
            //点击一下开始线程通信
            findViewById(R.id.button).setOnClickListener(new View.OnClickListener() {
                @Override
                public void onClick(View v) {
                    //主线程中给子线程发送消息
                    threadExchangeData(sonThread.sonHandler);
                }
            });
        }
    
        /** * 用于线程间通信的方法，《发送方》 调用 * * @param handler 《接收方》的Handler */
        private void threadExchangeData(Handler handler) {
            Message msg = Message.obtain();
            String currThreadName = Thread.currentThread().getName();
            int data = new Random().nextInt();
            msg.obj = data;
            Log.d(TAG, "[" + currThreadName + "] 发出随机数： " + data);
            handler.sendMessage(msg);
        }
    
        private final class SonThread extends Thread { 
            private Handler sonHandler = null;
    
            @Override
            public void run() {
                super.run();
                //初始化looper
                Looper.prepare();
                sonHandler = new Handler() {
                    @Override
                    public void handleMessage(Message msg) {
                        super.handleMessage(msg);
                        int data = (int) msg.obj;
                        String threadName = Thread.currentThread().getName();
                        Log.d(TAG, "[" + threadName + "] 收到随机数: " + data);
                        //在子线程中给主线程发消息
                        threadExchangeData(mianHandler);
                    }
                };
                //启动消息循环
                Looper.loop();
            }
        }
    
        /** * 主线程的Handler */
        private Handler mianHandler = new Handler() {
            @Override
            public void handleMessage(Message msg) {
                super.handleMessage(msg);
                int data = (int) msg.obj;
                String threadName = Thread.currentThread().getName();
                Log.d(TAG, "[" + threadName + "] 收到随机数: " + data);
            }
        };
    }

![这里写图片描述][SouthEast]

[SouthEast]: /images/20220616/3a9c1e9c8a504411a369c0aea9eea3b9.png