IdelHandler源码分析

发表于 2023/05/22

作者 哆啦A梦

8 分钟阅读

IdelHandler源码分析

IdleHandler是一个位于MessageQueue中的接口，源码如下：

  
public static interface IdleHandler {
    /**
     * Called when the message queue has run out of messages and will now
     * wait for more.  Return true to keep your idle handler active, false
     * to have it removed.  This may be called if there are still messages
     * pending in the queue, but they are all scheduled to be dispatched
     * after the current time.
     */
    boolean queueIdle();
}

IdleHandler中有一个queueIdle方法，根据方法上的注释可以知道这个方法会在MessageQueue中没有消息时或者只有延迟消息时才会被调用。方法的返回值是一个boolean值，返回true会将IdleHandler保留，否则会将其移除。

MessageQueue中关于IdleHandler的方法有两个：

  
// 存放IdleHandler的集合
private final ArrayList<IdleHandler> mIdleHandlers = new ArrayList<IdleHandler>();

// 添加IdleHandler
public void addIdleHandler(@NonNull IdleHandler handler) {
  if (handler == null) {
    throw new NullPointerException("Can't add a null IdleHandler");
  }
  synchronized (this) {
    mIdleHandlers.add(handler);
  }
}

// 移除IdleHandler
public void removeIdleHandler(@NonNull IdleHandler handler) {
  synchronized (this) {
    mIdleHandlers.remove(handler);
  }
}

在MessageQueue中维护了一个IdleHandler集合，并且提供了添加IdleHandler和移除IdleHandler的方法。可以通过 Looper.myQueue().addIdleHandler(new Idler()) 添加一个IdleHandler。

mIdleHandlers是在MessageQueue中被执行的，相关代码如下;

  
Message next() {
  // 初次执行pendingIdleHandlerCount 的值是-1
  int pendingIdleHandlerCount = -1; 
  int nextPollTimeoutMillis = 0;
  for (;;) {
    if (nextPollTimeoutMillis != 0) {
      Binder.flushPendingCommands();
    }
    // 阻塞方法，调用native层的epoll监听文件描述符的写入事件来实现
    // 如果 nextPollTimeoutMillis = -1，则会一直阻塞，不会超时
    // 如果 nextPollTimeoutMillis = 0，不会阻塞,立即返回
    // 如果 nextPollTimeoutMillis >0,表示最长的阻塞时间为nextPollTimeoutMillis，如果期间被唤醒则立即返回
    nativePollOnce(ptr, nextPollTimeoutMillis);

    synchronized (this) {
      // ... 省略消息处理相关逻辑

      // 1.pendingIdleHandlerCount默认值为-1，满足第一个条件
      // 2.没有消息，或者当前没有要执行的消息
      // 同时满足以上两个条件才会进入if语句
      if (pendingIdleHandlerCount < 0
          && (mMessages == null || now < mMessages.when)) {
        // 获取IdleHandler的个数并赋值给pendingIdleHandlerCount
        pendingIdleHandlerCount = mIdleHandlers.size();
      }

      if (pendingIdleHandlerCount <= 0) {
        // 没有要执行的IdleHandler
        mBlocked = true;
        continue;
      }

      if (mPendingIdleHandlers == null) {
        // 初始化一个最小值为4的IdleHandler数组
        mPendingIdleHandlers = new IdleHandler[Math.max(pendingIdleHandlerCount, 4)];
      }
      // 将mIdleHandlers添加到数组中
      mPendingIdleHandlers = mIdleHandlers.toArray(mPendingIdleHandlers);
    }

    // 遍历数组执行IdleHandler
    for (int i = 0; i < pendingIdleHandlerCount; i++) {
      // 取出IdleHandler
      final IdleHandler idler = mPendingIdleHandlers[i];
      mPendingIdleHandlers[i] = null; // release the reference to the handler

      boolean keep = false;
      try {
        // 执行IdleHandler的queueIdle，返回值表示是否要保留IdleHandler
        keep = idler.queueIdle();
      } catch (Throwable t) {
        Log.wtf(TAG, "IdleHandler threw exception", t);
      }

      if (!keep) {
        synchronized (this) {
          // 不保留则从集合中移除IdleHandler
          mIdleHandlers.remove(idler);
        }
      }
    }

    pendingIdleHandlerCount = 0;

    nextPollTimeoutMillis = 0;
  }
}

IdleHandler是在MessageQueue中没有可用消息时发生作用的，如果想要在消息处理空闲时做一些事情，就可以在当前线程的消息队列中加入IdleHandler，并重写Idle的queueIdle函数。
IdleHandler的作用次数可为一次或者多次，取决于queueIdle方法的返回值，如果返回false，那么执行完这个方法后便会从集合中移除，如果返回true，意味着每次只要消息队列空闲就会调用一次queueIdle方法。

IdelHandler源码分析

相关面试题

1. IdleHandler是什么，有什么用？

2. 如果消息队列一直没有消息，为什么queueIdle方法不会被无限调用（死循环）？

2. MessageQueue 提供了 add/remove IdleHandler 的方法，是否需要成对使用？

3. 是否可以将一些不重要的启动服务移到IdleHandler中处理？

4. IdleHandler 的 queueIdle运行在哪个线程？

5. 为什么 Activity.finish() 之后 10s 才 onDestroy ？

热门标签