Analisis kod contoh halangan penyegerakan Java Handler

1. Dalam proses memuatkan dan melukis View, terdapat kelas koreografer, mKoreografer.

mTraversalBarrier = mHandler.getLooper().postSyncBarrier();Masukkan mesej penghalang penyegerakan ke dalam mesej MessageQueue, msg.target==null, nilai pulangan mTraversalBarrier ialah nilai token int.

  void scheduleTraversals() {
    if (!mTraversalScheduled) {
      mTraversalScheduled = true;
       //向消息队列插入一个同步屏障的消息。msg.target==null的消息
             mTraversalBarrier = mHandler.getLooper().postSyncBarrier();
             mChoreographer.postCallback(
                  Choreographer.CALLBACK_TRAVERSAL, mTraversalRunnable, null);
    }
  }

Kaedah mChoreographer.postCallback() akan melaksanakan kod dalam mTraversalRunnable.

mHandler.getLooper().removeSyncBarrier(mTraversalBarrier);Ini akan mengalih keluar mesej halangan penyegerakan dalam MessageQueue berdasarkan nilai token yang dijana di atas.

 final TraversalRunnable mTraversalRunnable = new TraversalRunnable();
 final class TraversalRunnable implements Runnable {
            @Override
            public void run() {
                doTraversal();
            }
  }
   void doTraversal() {
      if (mTraversalScheduled) {
          mTraversalScheduled = false;
          //移除同步屏障消息
          mHandler.getLooper().removeSyncBarrier(mTraversalBarrier);
          //在这个方法中会调用 measure layout draw，view的绘制绘制流程的方法
          performTraversals();
      }
    }

Lihat baris kod ini mHandler.getLooper().postSyncBarrier() untuk melihat cara sistem mengendalikannya.

Mendapat Mesej tanpa pengendali.

int enqueueSyncBarrier(long when) {
        // Enqueue a new sync barrier token.
        // We don't need to wake the queue because the purpose of a barrier is to stall it.
        synchronized (this) {
            final int token = mNextBarrierToken++;
            // 这个msg.target没有被赋值
            final Message msg = Message.obtain();
            msg.markInUse();
            msg.when = when;
            msg.arg1 = token;
            Message prev = null;
            Message p = mMessages;
            if (when != 0) {
                while (p != null && p.when <= when) {
                    prev = p;
                    p = p.next;
                }
            }
            if (prev != null) { // invariant: p == prev.next
                msg.next = p;
                prev.next = msg;
            } else {
                msg.next = p;
                mMessages = msg;
            }
            return token;
        }
    }

Biasanya kami menghantar mesej melalui pengendali, dan pengendali tidak dibenarkan kosong.

 boolean enqueueMessage(Message msg, long when) {
        if (msg.target == null) {
            throw new IllegalArgumentException("Message must have a target.");
        }
   ...........
}

Jadi mengapa sistem menghantar mesej dengan pengendali kosong?

Mari kita lihat dahulu apa yang dilakukan oleh mChoreographer selepas menghantar mesej halangan penyegerakan?

Satu lagi mesej tak segerak telah dihantar: msg.setAsynchronous(true).

private void postCallbackDelayedInternal(int callbackType,
            Object action, Object token, long delayMillis) {
      synchronized (mLock) {
            final long now = SystemClock.uptimeMillis();
            final long dueTime = now + delayMillis;
            mCallbackQueues[callbackType].addCallbackLocked(dueTime, action, token);
            if (dueTime <= now) {
                scheduleFrameLocked(now);
            } else {
                Message msg = mHandler.obtainMessage(MSG_DO_SCHEDULE_CALLBACK, action);
                msg.arg1 = callbackType;
                //将消息设置为异步消息
                msg.setAsynchronous(true);
                mHandler.sendMessageAtTime(msg, dueTime);
            }
        }
}

Seterusnya, mari kita lihat cara MessageQueue mengalih keluar mesej dan cara ia mengendalikan mesej halangan penyegerakan ini.

 Message next() {
            synchronized (this) {
                // Try to retrieve the next message.  Return if found.
                final long now = SystemClock.uptimeMillis();
                Message prevMsg = null;
                Message msg = mMessages;
                //如果msg.target==null说明我们已经向消息队里中插入了一条屏障消息。
                //此时会进入到这个循环中，找到msg.isAsynchronous==true的异步消息。
                //通常我们发送的都是同步消息isAsynchronous = false的，并且msg.target不能为null的。
                if (msg != null && msg.target == null) {
                    // Stalled by a barrier.  Find the next asynchronous message in the queue.
                    do {
                        prevMsg = msg;
                        msg = msg.next;
                    } while (msg != null && !msg.isAsynchronous());//msg.isAsynchronous==true时结束循环，说明找到了这个异步消息。
                }
                if (msg != null) {//找到了同步屏障的异步消息后，直接返回
                    if (now < msg.when) {
                        // Next message is not ready.  Set a timeout to wake up when it is ready.
                        nextPollTimeoutMillis = (int) Math.min(msg.when - now, Integer.MAX_VALUE);
                    } else {
                        // Got a message.
                        mBlocked = false;
                        if (prevMsg != null) {
                            prevMsg.next = msg.next;
                        } else {
                            mMessages = msg.next;
                        }
                        msg.next = null;
                        if (false) Log.v("MessageQueue", "Returning message: " + msg);
                        return msg;
                    }
                } else {//没有找到的话则进入休眠直到下一次被唤醒
                    // No more messages.
                    nextPollTimeoutMillis = -1;
                }
        }
    }

Apabila membatalkan, mula-mula tentukan sama ada msg.target adalah batal, dan kemudian pergi melalui gelung sementara untuk mencari mesej yang msg.isAsynchronous() == benar. Itulah mesej tak segerak yang dihantar di atas. Biasanya mesej yang kami hantar ialah mesej segerak, dan msg.setAsynchronous(true) tidak akan ditetapkan.

Tujuan sistem adalah untuk memproses mesej tak segerak ini terlebih dahulu. Semua mesej penyegerakan akan diletakkan di belakang, sama seperti penghalang, jadi operasi sedemikian dipanggil halangan penyegerakan, dan pemprosesan mesej halangan penyegerakan mempunyai keutamaan yang lebih tinggi.

Oleh kerana mChoreographer kelas koreograf bertanggungjawab untuk pemaparan skrin, ia perlu memproses isyarat dari lapisan bawah tepat pada masanya untuk memastikan kekerapan penyegaran antara muka.

Atas ialah kandungan terperinci Analisis kod contoh halangan penyegerakan Java Handler. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!