美文网首页
直观理解Handler机制

直观理解Handler机制

作者: walker113 | 来源:发表于2020-12-15 09:55 被阅读0次

概念

网上有很多Handler的文档,写的很详细,但有时越详细的文章看起来越是云里雾里,比如说 一个线程能否创建多个Handler,Handler跟Looper之间的对应关系等等,感觉越绕越晕,如果大家也有这方面的困惑,不妨花些许时间来看看这篇文章;
文章从最简单的概念来理解Handler;

ThreadLocal

首先要了解ThreadLocal的作用,ThreadLocal是一个线程内部的数据存储类,数据存储有只有当前线程能够获取对应数据,别的线程无法获取到。
上面的介绍可能大家理解起来有点抽象,我们通过代码来理解会比较直观;

public static void main(String[] args) {
    // 定义一个ThreadLocal 对象,泛型使用的Integer,分别在主线程,Thread_1 和 Thread_2中设置、访问 threadLocal 的值;
     ThreadLocal<Integer> threadLocal = new ThreadLocal<>();
     threadLocal.set(5);
     new Thread("Thread_1") {
         @Override
         public void run() {
             for (int i = 0; i< 10;i++) {
                 threadLocal.set(i);
             }
            System.out.println(Thread.currentThread().getName() + ", " + threadLocal.get());
         }
     }.start();

     new Thread("Thread_2") {
         @Override
         public void run() {
             for (int i = 11; i< 20;i++) {
                 threadLocal.set(i);
             }
             System.out.println(Thread.currentThread().getName() + ", " + threadLocal.get());
         }
     }.start();
     System.out.println(Thread.currentThread().getName() + ", " + threadLocal.get());
 }

output

Thread_1, 9
main, 5
Thread_2, 19

从打印的日志可以看出,虽然不同线程访问的是同一个ThreadLocal对象,但不同线程获取到的值是不同的,这就是ThradLocal的作用;


为一个线程创建Looper,开启消息循环

我们来为一个线程创建Looper,并开启消息循环,然后再把各个关键代码抽离处理,耦合在一起,这样便于大家对线程切换有个比较直观的理解;

new Thread() {
    @Overvide
    public void run() {
        Looper.prepare();
        Handler handler = new Handler();
        Looper.loop();
    }
}.start();

我们可以把这段代码解耦的部分抽出来,写的更加直观一些;

private Handler handler
new Thread("Thread_Looper") {
    @Overvide
    public void run() {
        // Looper.prepare(); 创建Looper,并为ThreadLocal赋值
        Looper looper = new Looper(); 
        {
            mQueue = new MessageQueue(quitAllowed);
        }
        sLocalThread.set(looper);

        // Handler handler = new Handler();
        handler = new Handler();
        {
            // 获取当前线程的Looper
            mLooper = Looper.myLooper();
            mQueue = mLooper.mQueue;
        }

        // Looper.loop(); loop()是静态方法,里面是一个for循环(for死循环)
        Looper me = myLooper();
        MessageQueue queue = me.mQueue;
        for(;;) {
            Message msg = queue.next(); // might block
        }
    }
}.start();

// 调用Handler往 Thread_Looper 线程发送消息
new Thread("Thread_SendMessage") {
    @Overvide
    public void run() {
        // mHandler.sendMessage();
        queue.enqueueMessage(msg, uptimeMillis);
    }
}

看到这里,Handler切换线程的逻辑应该就很好理解了,Handler持有Looper对象的MessageQueue,线程(Thread_SendMessage)调用 handler.sendMessage()时,实际做的是往Looper对象的MessageQueue中插入消息,线程(Thread_Looper)在for循环中,获取到消息,并处理消息,这就完成了线程切换的过程;

image.png

关键代码

Looper

class Looper {
    static LocalThread sLocalThread;
    Thread mThread;
    MessageQueue mQueue;
    static void prepare() {
        sLocalThread.set(new Looper());
    }
    static Looper myLooper() {
        sLocalThread.get();
    }
    static void loop() {
        Looper me = Looper.myLooper();
        MessageQueue queue = me.mQueue();
        for(;;) {
        }
    }
    Looper() {
        mQueue = new MessageQueue(quitAllowed);
        mThread = Thread.currentThread();
    }
}

Handler

class Handler {
    Looper mLooper;
    MessageQueue mQueue;
    public Handler() {
        mLooper = Looper.myLooper();
        mQueue = mLooper.mQueue;
    }
    public boolean sendMessageAtTime(Message msg, long uptimeMillis) {
        MessageQueue queue = mQueue;
        return enqueueMessage(queue, msg, uptimeMillis);
    }
    private boolean enqueueMessage(MessageQueue queue, Message msg,
        long uptimeMillis) {
        msg.target = this;
        return queue.enqueueMessage(msg, uptimeMillis);
    }
}

相关文章

网友评论

      本文标题:直观理解Handler机制

      本文链接:https://www.haomeiwen.com/subject/ghiigktx.html