Handler机制

2021-03-08  本文已影响0人  Android小悟空

1、handler使用

子线程与主线程通信:
public class HandlerActivity extends AppCompatActivity {

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

        // 方式1(其内部也是调用等sendMessage):
        CustomHandler handler = new CustomHandler(this);
        new Thread(new Runnable() {
            @Override
            public void run() {
                //耗时操作 ***

                //完成耗时操作切换到主线程
                handler.post(new Runnable() {
                    @Override
                    public void run() {
                        //更新UI
                    }
                });
            }
        });
        // 方式2 :
        new Thread(new Runnable() {
            @Override
            public void run() {
                Message message = handler.obtainMessage();
                message.obj = "123";
                message.what = 3;
                //通过这个方法,可以将消息设置为异步消息
                message.setAsynchronous(true);
                handler.sendMessage(message);

            }
        });
    }

    //静态类Handler来避免内存泄漏,但是由于静态类不能直接持有Activity的引用,所以可以用弱引用来解决
    private static class CustomHandler extends Handler{
        WeakReference<Activity> activityWeakReference;
        CustomHandler(Activity activity) {
            activityWeakReference = new WeakReference<>(activity);
        }

        @Override
        public void handleMessage(Message msg) {
            Activity thisA = activityWeakReference.get();
        }
    }
}

//post使用示例:
new Thread(new Runnable() {
   @Override
   public void run() {
       /**
          耗时操作
        */
      handler.post(new Runnable() {
          @Override
          public void run() {
              /**
                更新UI
               */
          }
      });
   }
 }).start();
 
从子线程切换到主线程的三种方式: 
final Handler handler = new Handler();
new Thread(new Runnable() {
    @Override
    public void run() {
        // 素描算法处理 耗时操作
        final Bitmap bitmap1 = SketchUtil.testGaussBlur(finalBitmap,1,1);
        final Bitmap bitmap2 = SketchUtil.testGaussBlur(finalBitmap,10,10);
        final Bitmap bitmap3 = SketchUtil.testGaussBlur(finalBitmap,20,20);

        // 三种切回主线程更新UI的方法
        imageView.post(new Runnable() {
            @Override
            public void run() {
                imageView.setImageBitmap(bitmap1); // 素描图
            }
        });

        runOnUiThread(new Runnable() {
            @Override
            public void run() {
                orignView.setImageBitmap(bitmap2); // 素描图
            }
        });

        handler.post(new Runnable() {
            @Override
            public void run() {
                threeView.setImageBitmap(bitmap3); // 素描图
            }
        });
    }
}).start();

通常我们在主线程中创建一个Handler,
然后重写该Handler的handlerMessage方法,可以看到该方法传入了一个参数Message,
该参数就是我们从其他线程传递过来的信息。
我们在来看下子线程中如何传递的信息,子线程通过Handler的obtainMessage()方法获取到一个Message实例,
我们来看看Message的几个属性:

最后通过sendMessage将Message发送出去。
Handler所在的线程通过handlerMessage方法就能收到具体的信息了,如何判断信息的来源呢?当然是通过what值啦。

主线程的Looper以及Loop.prepare()是在ActivityThread中创建的
子线程与子线程通信:
private Handler handler;
private void handlerDemoByTwoWorkThread() {
    Thread hanMeiMeiThread = new Thread() {
        @Override
        public void run() {
            Looper.prepare();
            handler = new Handler() {
                @Override
                public void handleMessage(Message msg) {
                    Log.d(TAG, "hanMeiMei receiver message: " + ((String) msg.obj));
                    Toast.makeText(MainActivity.this, ((String) msg.obj), Toast.LENGTH_SHORT).show();
                }
            };
            Looper.loop();
        }
    };
    Thread liLeiThread = new Thread() {
        @Override
        public void run() {
            try {
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            Message message = handler.obtainMessage();
            message.obj = "Hi MeiMei";
            handler.sendMessage(message);
        }
    };
    hanMeiMeiThread.setName("韩梅梅 Thread");
    hanMeiMeiThread.start();
    liLeiThread.setName("李雷 Thread");
    liLeiThread.start();
}

Android的消息机制之ThreadLocal的工作原理

关键类

Looper.prepare()

子线程创建Handler前一定要执行此方法来创建Looper

原理

注意 :

Looper.loop() 中有一个for(;;)循环来调用MessageQueue.next()
MessageQueue.next()中也有一个for(;;)循环,这当中涉及到一个阻塞的问题

延时消息如何处理的

Android中为什么主线程不会因为Looper.loop()里的死循环卡死?

binder线程和主线程的关系:

在ActivityThread中,有个main()方法,这里创建到MainLooper和binder线程:

public static void main(String[] args) {
    ....

    //创建Looper和MessageQueue对象,用于处理主线程的消息
    Looper.prepareMainLooper();

    //创建ActivityThread对象
    ActivityThread thread = new ActivityThread(); 

    //建立Binder通道 (创建新线程)
    thread.attach(false);

    Looper.loop(); //消息循环运行
    throw new RuntimeException("Main thread loop unexpectedly exited");
}

thread.attach(false);便会创建一个Binder线程.该Binder线程通过Handler将Message发送给主线程

ActivityThread是继承自Thread吗?

不是,ActivityThread并没有真正继承Thread类,只是往往运行在主线程,该人以线程的感觉,其实承载ActivityThread的主线程就是由Zygote fork而创建的进程。

为什么主线程一直开着确并没有特别消耗CPU资源:

Linux pipe/epoll机制
1、首先明确一点,线程有一个阻塞状态,当线程处于阻塞状态时,会释放CPU资源
2、在主线程进入循环之前,会创建一个Linux的Pipe管道,这个管道的作用就是让我们的消息队列是空的时候,可以进入等待状态(阻塞状态),并且有消息的时候再唤醒主线程
3、这个往Pipe管道中塞消息并且再唤醒主线程的机制就时epoll机制,调用的是epoll.wait方法

Activity的生命周期是怎么实现在死循环体外能够执行起来的?

主线程的死循环一直运行是不是特别消耗CPU资源呢?

Handler怎么实现线程切换的

一个线程可以创建多个Handler吗

一个线程可以创建多个Handler,但只能创建一个Looper,一个MessageQueue。Handler跟Looper之间没有对应关系。
多个handler时,谁发消息谁处理消息

Handler是怎么知道如何把消息发回到callback中还是handleMessage中?

Handler中有个dispatchMessage方法,在这里面判断msg.callback是否为空,不为空就发到runCallBack中,为空就发到handleMessage中

为什么一个线程只能创建一个looper

Looper的prepare方法中明确有判断,如果存在looper并且再次调用prepare时,会抛出RuntimeException

handler 的同步屏障机制

1、屏障消息和普通消息的区别是屏障消息没有tartget。
2、设置(postSyncBarrier)和移除(removeSyncBarrier)同步屏障消息的方法在MessageQueue中,且是私有的,设置的话需要通过反射调用

View.post()中的Handler机制

Handler 内存泄漏原因?为什么其他的内部类没有说过有这个问题?

泄漏链:Looper中持有MessageQueue的引用、MessageQueue中持有Message的引用,message持有handler的引用,而handler又持有外部类的引用、当外部类被销毁时,因为Looper是一直存在的,所以会泄漏

任何一个内部类,只要它持有外部类的引用,那么当内部类进行耗时操作,然后外部类被销毁后,都会导致内存泄漏,原因是内部类持有外部类的引用无法释放

为何主线程可以new Handler?如果想要在子线程中new Handler要做些什么准备?

通过Looper.prepare创建Looper
通过Looper.loop()让它循环取消息

子线程中维护的Looper,消息队列无消息的时候的处理方案是什么?有什么用?

既然可以存在多个Handler往MessageQueue中添加数据(发消息时各个Handler可能处于不同线程),那它内部是如何确保线程安全的?

MessageQueue的放消息和取消息都是通过加锁来保证线程安全的

我们使用Message时应该如何创建它?

handler.obtainMessage();

handler.obtainMessage()和new Message有什么区别

obtainmessage()是从消息池中拿来一个msg 不需要另开辟空间new

Message.what什么情况下为0

1、创建一个message但是不指定what的情况下
2、通过handler.post一个runnable时, runnable会被封装为一个message, 里面的what为0

什么是HandlerThread

一个线程如何安全退出Handler

可以通过 Looper.quiet

Looper的quit方法和quitSafely方法

1、都是退出handler、都不再接收新消息
2、quit直接清空messageQueue中的所有消息
3、quitSafely只清空messageQueue中的所有延时消息

IdleHandler (闲时机制)

Looper.myQueue().addIdleHandler(new MessageQueue.IdleHandler() {
    @Override
    public boolean queueIdle() { // 消息处理完成时的回调
        return false;
    }
});

IdleHandler是一个回调接口,可以通过MessageQueue的addIdleHandler添加实现类。当MessageQueue中的任务暂时处理完了(没有新任务或者下一个任务延时在之后),这个时候会回调这个接口,返回false,那么就会移除它,返回true就会在下次message处理完了的时候继续回调。

上一篇下一篇

猜你喜欢

热点阅读