Web Totals

Học từ Facebook #78: setImmediate bằng postMessage, gom chuột theo frame

Facebook tự viết setImmediate bằng MessageChannel và postMessage để né mức kẹp 4ms của setTimeout, và gom mousemove thành một lần xử lý mỗi frame. Bản rút cạn hàng đợi gốc có thể bỏ đói trình duyệt.

hunghg255hunghg25525 min read
#facebook#event-loop#scheduler#pointer-events#performance
Học từ Facebook #78: setImmediate bằng postMessage, gom chuột theo frame

Bạn muốn chạy một việc "ngay sau khi code hiện tại xong", nhưng không chạy luôn trong stack hiện tại. Cách quen tay là setTimeout(fn, 0). Vấn đề:

  • Trình duyệt kẹp timer lồng nhau: từ lần lồng thứ 5 trở đi, setTimeout(fn, 0) chờ tối thiểu 4ms (theo chuẩn HTML). Một chuỗi 300 việc gọi nối nhau mất hơn 1 giây chỉ để chờ.
  • Promise.resolve().then(fn) thì quá nhanh: microtask chạy trước khi trình duyệt kịp vẽ hay xử lý input. Một chuỗi microtask dài làm đứng trang.

Cần một thứ ở giữa: một macrotask không bị kẹp 4ms. Đó là setImmediate, API mà chỉ IE và Node có. Facebook tự viết lại nó trong module ImmediateImplementation.

Cùng họ "đừng làm việc thừa trong vòng lặp sự kiện" là DOMMouseMoveTracker: chuột bắn mousemove 60 đến 1000 lần mỗi giây (chuột gaming), nhưng màn hình chỉ vẽ 60 đến 120 lần. Xử lý từng sự kiện là phí.

Tip

Tóm tắt

  • ImmediateImplementation xếp việc vào hàng đợi rồi tự đánh thức bằng MessageChannel hoặc window.postMessage: một macrotask, không bị kẹp 4ms. Khi đang ở trong một sự kiện người dùng thật (click, pointerup, submit…), nó ưu tiên postMessage.
  • Bản gốc rút cạn hàng đợi, kể cả việc thêm vào trong lúc rút. Một chuỗi setImmediate đệ quy vì vậy chạy hết trong một task duy nhất: trong thử nghiệm 20.000 bước, một setTimeout(0) đặt trước không chạy được lần nào cho tới khi chuỗi xong.
  • DOMMouseMoveTracker cộng dồn delta chuột, chỉ gọi handler một lần mỗi frame qua requestAnimationFrame, và xả phần còn lại khi thả chuột.
  • Bản viết lại chỉ rút những việc đã có trước lượt hiện tại, dùng Pointer Events + pointer capture; trình duyệt mới có sẵn scheduler.postTask cho vai trò tương tự.

#Facebook làm thế nào?

#ImmediateImplementation (bundle 22.js, 1.js; bản cũ không có nhánh thử nghiệm trong Scroll/TimeSlice.js)

Module là bản chuyển thể từ polyfill setImmediate quen thuộc (của YuzuJS), có thêm một nhánh thử nghiệm. Lõi là một danh sách liên kết và một vòng rút (đổi tên biến cho dễ đọc, bản đầy đủ trong spoiler):

while (!running && (task = head.next)) {   // đi tới cuối danh sách, kể cả việc mới nối vào
  head = task;
  if ((cb = callbacks[task.handle])) { running = true; try { cb(); running = false; } finally { … } }
}
js
Code gốc đã đổi tên biến: hàng đợi và vòng rút
const callbacks = {};                    // handle → callback
let head = {}, tail = head, running = false;
const token = 'setImmediate$' + Math.random() + '$';

function enqueue([fn, ...args]) {
  callbacks[nextHandle] = () => fn(...args);
  tail = tail.next = { handle: nextHandle++ };   // danh sách liên kết, head là nút đã chạy
  return tail.handle;
}

function drain() {
  let task, cb;
  while (!running && (task = head.next)) {       // chạy tới khi danh sách rỗng
    head = task;
    if ((cb = callbacks[task.handle])) {
      running = true;
      try { cb(); running = false; }
      finally {
        delete callbacks[task.handle];
        if (running) { running = false; if (head.next) wake(drain); }  // lỗi: hẹn lượt sau
      }
    }
  }
}

function inTrustedUserEvent() {
  const e = window.event;
  return e && (e.isTrusted && ['change', 'click', 'contextmenu', 'dblclick', 'mouseup',
      'pointerup', 'reset', 'submit', 'touchend'].includes(e.type)
    || e.type === 'message' && e.source === window && e.data.indexOf(token) === 0);
}
js

Bản trong Scroll/TimeSlice.js chỉ có phần polyfill: không có inTrustedUserEvent và cờ thử nghiệm. Bản trong 22.js và 1.js thì có. Phần đánh thức chọn đường theo thứ tự: postMessage (nếu trình duyệt gọi handler message bất đồng bộ) → MessageChannel → thẻ <script> với onreadystatechange (IE cũ) → setTimeout. Khi bật cờ thử nghiệm prefer_message_channel, nó dùng MessageChannel làm mặc định và chỉ quay sang postMessage (qua originalPostMessage nếu có) khi inTrustedUserEvent() đúng. Nhánh MessageChannel có cờ "đang bay", nên nhiều lần setImmediate liên tiếp chỉ gửi một message; nhánh postMessage gửi một message cho mỗi lần gọi (chuỗi token + handle), message đầu tiên rút hết, các message sau tới nơi thì thấy hàng đợi rỗng.

Vì sao ưu tiên postMessage khi đang trong một click thật? Code không giải thích. Có lẽ là để giữ "user activation": một số API (mở popup, vào fullscreen, phát âm thanh) chỉ cho phép khi đang trong cử chỉ người dùng. Các trình duyệt cũ coi việc chạy trong handler message của chính window gửi ngay sau click vẫn còn trong cử chỉ đó; MessageChannel có lẽ không được đối xử như vậy.

Khi message tới, drain đi theo head.next tới cuối danh sách: callback nào được setImmediate trong lúc rút cũng nối vào đuôi và được chạy luôn, trong cùng task. Đây là chỗ đáng chú ý (xem phần "Bên trong").

#DOMMouseMoveTracker (bundle 199.js)

Mỗi mousemove chỉ cộng dồn, việc thật để cho frame kế tiếp:

onMouseMove = (e) => {
  this.dx += e.clientX - this.x; this.dy += e.clientY - this.y;
  this.x = e.clientX; this.y = e.clientY;
  this.frame ??= requestAnimationFramePolyfill(this.didMouseMove);   // một lần onMove mỗi frame
};
js

onMouseUp gọi didMouseMove ngay nếu còn frame đang chờ, rồi mới onMoveEnd: phần dịch chuyển cuối không bị mất.

Code gốc đã đổi tên biến: DOMMouseMoveTracker
class DOMMouseMoveTracker {
  captureMouseMoves(e) {
    if (!this.moveListener) {
      this.moveListener = listen(document, 'mousemove', this.onMouseMove);
      this.upListener = listen(document, 'mouseup', this.onMouseUp);
    }
    this.isDragging = true; this.x = e.clientX; this.y = e.clientY; this.dx = this.dy = 0;
    e.preventDefault();
  }
  onMouseMove = (e) => {
    this.dx += e.clientX - this.x; this.dy += e.clientY - this.y;   // chỉ cộng dồn
    this.x = e.clientX; this.y = e.clientY;
    this.frame ??= requestAnimationFramePolyfill(this.didMouseMove);
    e.preventDefault();
  };
  didMouseMove = () => {
    this.frame = null;
    this.onMove(this.dx, this.dy);                                   // một lần mỗi frame
    this.dx = this.dy = 0;
  };
  onMouseUp = () => {
    if (this.frame) this.didMouseMove();                             // xả phần còn treo
    this.onMoveEnd();
  };
  releaseMouseMoves() { /* gỡ listener, cancelAnimationFrame */ }
}
js

Nghe trên document để vẫn nhận sự kiện khi chuột chạy ra ngoài phần tử đang kéo (thanh cuộn tuỳ biến, cột bảng co giãn). Chỉ có chuột: không có touch hay bút.

sequenceDiagram
  participant M as Chuột
  participant T as Tracker
  participant R as rAF
  participant H as onMove
  M->>T: mousemove (dx += 3)
  T->>R: xin 1 frame
  M->>T: mousemove (dx += 4)
  M->>T: mousemove (dx += 2)
  R->>T: tới frame
  T->>H: onMove(9, ...) một lần
  M->>T: mousemove (dx += 1)
  M->>T: mouseup
  T->>H: xả onMove(1, ...)

#Bên trong: task, microtask và mức kẹp 4ms

Mỗi vòng của event loop: lấy một task (timer, message, sự kiện input) → chạy hết microtask → nếu tới lúc thì vẽ (chạy requestAnimationFrame, style, layout, paint). Có ba hệ quả:

  1. setTimeout(fn, 0) không phải 0. Chuẩn HTML cho phép kẹp tối thiểu 4ms khi timer lồng quá 5 cấp; trình duyệt chính đều làm vậy. Tab ẩn còn bị kẹp 1 giây.
  2. Message không bị kẹp. MessageChannel.port.postMessage xếp một task mới ngay lập tức. React Scheduler cũng dùng đúng mẹo này.
  3. Một task dài chặn tất cả. Trong lúc task chạy, không có vẽ, không có input. Nếu bộ rút hàng đợi chạy luôn những việc mới được thêm, một chuỗi setImmediate đệ quy biến thành một task vô tận.

Thử nghiệm với Node (cùng logic, đổi MessageChannel của Node): đặt setTimeout(check, 0) rồi bắt đầu chuỗi 20.000 setImmediate nối nhau.

Cách rút Timer chạy khi chuỗi ở bước
Rút cạn kiểu Facebook không chạy cho tới khi chuỗi xong
Chỉ rút việc có trước lượt (bản viết lại) khoảng bước 1.000

Bản gốc có lẽ không gặp vấn đề vì code Facebook ít khi gọi setImmediate đệ quy dài; nhưng nếu bạn dùng nó để "chia nhỏ việc nặng cho khỏi đứng trang" thì nó không chia gì cả. Demo phần 1 cho thấy điều đó qua số frame vẽ được trong lúc chạy.

#Viết lại

Phần rút hàng đợi: chụp tail lúc bắt đầu, chỉ chạy tới đó.

src/lib/immediate.ts
  function drain() {
    wakeScheduled = false;
    // Chỉ chạy những việc đã có TRƯỚC lượt này. Việc được thêm trong lúc chạy đợi lượt sau,
    // nhờ vậy một chuỗi setImmediate gọi đệ quy vẫn nhường cho trình duyệt vẽ và xử lý input.
    const end = tail;
    let task: Task | null;
    while (!running && cursor !== end && (task = cursor.next)) {
      cursor = task;
      const callback = callbacks.get(task.handle);
      if (!callback) continue; // đã bị clearImmediate
      callbacks.delete(task.handle);
      running = true;
      try {
        callback();
        running = false;
      } finally {
        if (running) {
          // callback vừa ném lỗi: hẹn chạy tiếp phần còn lại rồi để lỗi bay ra ngoài
          running = false;
          if (cursor.next) wake();
        }
      }
    }
    if (!cursor.next) {
      // hàng đợi rỗng: thu hồi danh sách để không giữ nút cũ trong bộ nhớ
      head.next = null;
      tail = cursor = head;
    }
  }
ts

Gom delta theo frame bằng Pointer Events:

src/lib/dragTracker.ts
  const flush = () => {
    frame = null;
    if (dx === 0 && dy === 0) return;
    stats.flushes++;
    const x = dx;
    const y = dy;
    dx = dy = 0;
    options.onMove(x, y);
  };

  const onMove = (event: PointerEvent) => {
    if (event.pointerId !== pointerId) return;
    stats.events++;
    dx += event.clientX - lastX;
    dy += event.clientY - lastY;
    lastX = event.clientX;
    lastY = event.clientY;
    if (frame === null) frame = schedule(flush);
  };
ts

#Đi qua code

  • const end = tail chụp đuôi danh sách lúc bắt đầu lượt. Vòng while dừng khi cursor tới end, nên việc được setImmediate trong lúc chạy nằm sau end và chờ lượt sau. Đó là toàn bộ khác biệt so với bản gốc, và là thứ làm chuỗi đệ quy nhường cho trình duyệt.
  • running chặn chạy lồng: nếu một callback tự gọi đồng bộ vào vòng rút (qua một đường lạ), vòng trong thoát ngay.
  • Callback ném lỗi thì running vẫn là true khi vào finally. Đó là dấu hiệu để hẹn một lượt mới cho phần còn lại, rồi để lỗi bay ra ngoài cho window.onerror thấy.
  • wake() (trong file đầy đủ) có cờ wakeScheduled: 1.000 lần setImmediate liên tiếp chỉ gửi một message. Demo "Xếp 1000 việc cùng lúc" đếm đúng con số này.
  • Ở tracker, flush đặt frame = null trước khi gọi onMove, để nếu onMove chậm và có pointermove mới tới trong lúc đó, frame sau vẫn được xin.

Khác bản gốc:

  • Chỉ rút những việc có trước lượt hiện tại; việc mới thêm chờ lượt sau, nên chuỗi đệ quy vẫn nhường cho trình duyệt vẽ.
  • Xử lý lỗi giữ như bản gốc (hẹn lượt mới cho phần còn lại rồi để lỗi bay ra); thêm thu hồi danh sách khi rỗng và đếm số lần đánh thức.
  • Bỏ nhánh postMessage-trong-cử-chỉ và nhánh <script> của IE; postMessage còn lại dùng token ngẫu nhiên và kiểm tra event.source.
  • Tracker dùng pointermove + setPointerCapture (chuột, cảm ứng, bút), thêm cancel() và pointercancel để huỷ mà không xả delta.
Xem toàn bộ src/lib/immediate.ts
src/lib/immediate.ts
/**
 * setImmediate tự viết (ý tưởng từ ImmediateImplementation của Facebook):
 * - Hàng đợi FIFO bằng danh sách liên kết, gọi lại bằng handle.
 * - Mỗi lần "đánh thức" chỉ gửi MỘT message; khi chạy thì làm hết các việc đã xếp hàng
 *   trước lượt đó trong cùng một task.
 * - Callback ném lỗi: phần còn lại được hẹn lượt sau rồi lỗi mới được ném tiếp
 *   (không nuốt lỗi, không bỏ rơi các việc đang xếp hàng).
 */

export type ImmediateTransport = 'message-channel' | 'post-message' | 'timeout';

type Task = { handle: number; next: Task | null };

export interface Immediate {
  setImmediate(fn: (...args: unknown[]) => void, ...args: unknown[]): number;
  clearImmediate(handle: number): void;
  readonly transport: ImmediateTransport;
  /** số lần thực sự gửi tín hiệu đánh thức (message/timer) */
  readonly wakes: number;
  dispose(): void;
}

export function createImmediate(preferred?: ImmediateTransport): Immediate {
  const callbacks = new Map<number, () => void>();
  let nextHandle = 1;
  const head: Task = { handle: 0, next: null }; // nút giả: head.next là việc kế tiếp
  let tail = head;
  let cursor = head;
  let running = false;
  let wakeScheduled = false;
  let wakes = 0;

  function drain() {
    wakeScheduled = false;
    // Chỉ chạy những việc đã có TRƯỚC lượt này. Việc được thêm trong lúc chạy đợi lượt sau,
    // nhờ vậy một chuỗi setImmediate gọi đệ quy vẫn nhường cho trình duyệt vẽ và xử lý input.
    const end = tail;
    let task: Task | null;
    while (!running && cursor !== end && (task = cursor.next)) {
      cursor = task;
      const callback = callbacks.get(task.handle);
      if (!callback) continue; // đã bị clearImmediate
      callbacks.delete(task.handle);
      running = true;
      try {
        callback();
        running = false;
      } finally {
        if (running) {
          // callback vừa ném lỗi: hẹn chạy tiếp phần còn lại rồi để lỗi bay ra ngoài
          running = false;
          if (cursor.next) wake();
        }
      }
    }
    if (!cursor.next) {
      // hàng đợi rỗng: thu hồi danh sách để không giữ nút cũ trong bộ nhớ
      head.next = null;
      tail = cursor = head;
    }
  }

  const transport: ImmediateTransport =
    preferred ??
    (typeof MessageChannel !== 'undefined'
      ? 'message-channel'
      : typeof window !== 'undefined' && typeof window.postMessage === 'function'
        ? 'post-message'
        : 'timeout');

  let wakeRaw: () => void;
  let dispose = () => {};

  if (transport === 'message-channel') {
    const channel = new MessageChannel();
    channel.port1.onmessage = drain;
    wakeRaw = () => channel.port2.postMessage(null);
    dispose = () => {
      channel.port1.onmessage = null;
      channel.port1.close();
    };
  } else if (transport === 'post-message') {
    // token ngẫu nhiên để không nhầm với message của script khác trên trang
    const token = `immediate$${Math.random().toString(36).slice(2)}`;
    const onMessage = (event: MessageEvent) => {
      if (event.source === window && event.data === token) drain();
    };
    window.addEventListener('message', onMessage);
    wakeRaw = () => window.postMessage(token, '*');
    dispose = () => window.removeEventListener('message', onMessage);
  } else {
    wakeRaw = () => setTimeout(drain, 0);
  }

  function wake() {
    if (wakeScheduled) return; // đã có một lần đánh thức đang bay: các việc mới đi chung chuyến
    wakeScheduled = true;
    wakes++;
    wakeRaw();
  }

  return {
    transport,
    get wakes() {
      return wakes;
    },
    setImmediate(fn, ...args) {
      const handle = nextHandle++;
      callbacks.set(handle, () => fn(...args));
      tail = tail.next = { handle, next: null };
      wake();
      return handle;
    },
    clearImmediate(handle) {
      callbacks.delete(handle);
    },
    dispose,
  };
}
ts
Xem toàn bộ src/lib/dragTracker.ts
src/lib/dragTracker.ts
/**
 * Kéo bằng con trỏ, gom delta theo khung hình (ý tưởng từ DOMMouseMoveTracker của Facebook):
 * mỗi pointermove chỉ CỘNG DỒN dx/dy, handler thật chạy tối đa một lần mỗi frame với tổng delta.
 * Khác bản gốc: dùng Pointer Events + pointer capture (chuột, cảm ứng, bút), xả delta còn treo
 * khi thả, và có cancel() để huỷ giữa chừng.
 */

export interface DragTrackerOptions {
  /** gọi tối đa 1 lần/frame với tổng dịch chuyển kể từ lần gọi trước */
  onMove: (dx: number, dy: number) => void;
  onEnd?: (cancelled: boolean) => void;
  /** đổi để test: mặc định requestAnimationFrame */
  schedule?: (cb: () => void) => number;
  cancelSchedule?: (id: number) => void;
}

export interface DragTracker {
  start(event: PointerEvent): void;
  cancel(): void;
  readonly dragging: boolean;
  /** số pointermove đã nhận và số lần onMove thực sự chạy, để so sánh */
  readonly stats: { events: number; flushes: number };
}

export function createDragTracker(target: HTMLElement, options: DragTrackerOptions): DragTracker {
  const schedule = options.schedule ?? ((cb) => requestAnimationFrame(cb));
  const cancelSchedule = options.cancelSchedule ?? ((id) => cancelAnimationFrame(id));
  let dragging = false;
  let pointerId = -1;
  let lastX = 0;
  let lastY = 0;
  let dx = 0;
  let dy = 0;
  let frame: number | null = null;
  const stats = { events: 0, flushes: 0 };

  const flush = () => {
    frame = null;
    if (dx === 0 && dy === 0) return;
    stats.flushes++;
    const x = dx;
    const y = dy;
    dx = dy = 0;
    options.onMove(x, y);
  };

  const onMove = (event: PointerEvent) => {
    if (event.pointerId !== pointerId) return;
    stats.events++;
    dx += event.clientX - lastX;
    dy += event.clientY - lastY;
    lastX = event.clientX;
    lastY = event.clientY;
    if (frame === null) frame = schedule(flush);
  };

  const stop = (cancelled: boolean) => {
    if (!dragging) return;
    if (frame !== null) cancelSchedule(frame);
    if (!cancelled) flush(); // xả delta cuối, không để "hụt" vài pixel khi thả
    frame = null;
    dx = dy = 0;
    dragging = false;
    target.removeEventListener('pointermove', onMove);
    target.removeEventListener('pointerup', onUp);
    target.removeEventListener('pointercancel', onCancel);
    if (target.hasPointerCapture?.(pointerId)) target.releasePointerCapture(pointerId);
    options.onEnd?.(cancelled);
  };
  const onUp = (event: PointerEvent) => event.pointerId === pointerId && stop(false);
  const onCancel = (event: PointerEvent) => event.pointerId === pointerId && stop(true);

  return {
    get dragging() {
      return dragging;
    },
    stats,
    start(event) {
      if (dragging) return;
      dragging = true;
      pointerId = event.pointerId;
      lastX = event.clientX;
      lastY = event.clientY;
      dx = dy = 0;
      // capture: vẫn nhận move/up khi con trỏ ra khỏi phần tử (thay cho nghe trên document)
      target.setPointerCapture?.(pointerId);
      target.addEventListener('pointermove', onMove);
      target.addEventListener('pointerup', onUp);
      target.addEventListener('pointercancel', onCancel);
      event.preventDefault();
    },
    cancel: () => stop(true),
  };
}
ts

#Tại sao không làm cách khác?

  • queueMicrotask/Promise.then: nhanh nhất, nhưng microtask chạy hết trước khi trình duyệt làm bất cứ gì khác. Dùng để "chia nhỏ việc nặng" là sai chỗ.
  • requestAnimationFrame: chỉ 60 đến 120 lần/giây, và dừng hẳn khi tab ẩn. Hợp cho việc gắn với vẽ (như tracker), không hợp cho hàng đợi việc chung.
  • requestIdleCallback: chỉ chạy khi rảnh, có thể chờ rất lâu; Safari chưa bật mặc định (tính tới 10/2026).
  • scheduler.postTask: đúng thứ cần (macrotask có độ ưu tiên, huỷ được bằng AbortSignal), nhưng chưa có ở Safari (tính tới 10/2026). Hàm tự viết vẫn cần làm fallback.
  • Xử lý từng pointermove: đúng nhưng phí; với chuột 1000Hz và handler 6ms, trang không theo kịp. Demo phần 2 đếm số lần xử lý của hai cách.

#Edge case và cạm bẫy

  • window.postMessage dùng chung với mọi script: iframe, extension cũng nghe message. Dùng token ngẫu nhiên, kiểm tra event.source === window, và đừng stopPropagation message không phải của mình. MessageChannel riêng tư hơn.
  • Tab ẩn: message không bị kẹp như timer, nên hàng đợi vẫn chạy khi tab ẩn. Tốt cho việc phải xong, nhưng tốn pin nếu là vòng lặp vô tận.
  • Delta cuối khi thả: nếu chỉ huỷ rAF lúc pointerup, phần dịch chuyển cuối bị mất, đối tượng "hụt" vài pixel. Phải xả trước khi kết thúc (bản gốc làm đúng).
  • Pointer capture thay cho nghe trên document: capture giữ sự kiện cả khi con trỏ ra ngoài iframe hay cửa sổ, và tự giải phóng khi pointerup. Nhớ touch-action: none trên phần tử kéo, nếu không trình duyệt cuộn trang và bắn pointercancel.
  • getCoalescedEvents(): trình duyệt đã gộp sẵn nhiều pointermove thành một sự kiện mỗi frame. Nếu cần vẽ nét bút mượt, lấy các điểm gộp từ đây; nếu chỉ cần delta tổng thì như tracker là đủ.

#Dùng trong dự án

import { createImmediate } from './immediate';
const imm = createImmediate();

// chia việc nặng thành nhiều lượt, trình duyệt vẫn vẽ giữa các lượt
function processInChunks<T>(items: T[], work: (item: T) => void, chunk = 200) {
  let i = 0;
  const step = () => {
    const end = Math.min(i + chunk, items.length);
    for (; i < end; i++) work(items[i]);
    if (i < items.length) imm.setImmediate(step);
  };
  imm.setImmediate(step);
}
ts

Tracker dùng cho tay nắm co giãn cột: createDragTracker(handle, { onMove: (dx) => column.setWidth(column.width + dx), onEnd: (cancelled) => !cancelled && column.save() }), rồi gọi tracker.start(e) trong pointerdown.

#Kiểm thử

Ví dụ test (bản phác, không có trong repo)
import { describe, expect, it, vi } from 'vitest';
import { createImmediate } from './immediate';
import { createDragTracker } from './dragTracker';

describe('createImmediate', () => {
  it('nhiều việc cùng lúc chỉ gửi một tín hiệu', async () => {
    const imm = createImmediate();
    const seen: number[] = [];
    for (let i = 0; i < 100; i++) imm.setImmediate(() => seen.push(i));
    await new Promise((r) => setTimeout(r, 10));
    expect(seen).toHaveLength(100);
    expect(imm.wakes).toBe(1);
  });

  it('chuỗi đệ quy nhường cho timer', async () => {
    const imm = createImmediate();
    let steps = 0, timerAt = -1;
    setTimeout(() => (timerAt = steps), 0);
    await new Promise<void>((done) => {
      const step = () => (++steps < 5000 ? imm.setImmediate(step) : done());
      imm.setImmediate(step);
    });
    expect(timerAt).toBeGreaterThan(0);
    expect(timerAt).toBeLessThan(5000);
  });

  it('clearImmediate bỏ việc chưa chạy', async () => {
    const imm = createImmediate();
    const fn = vi.fn();
    imm.clearImmediate(imm.setImmediate(fn));
    await new Promise((r) => setTimeout(r, 10));
    expect(fn).not.toHaveBeenCalled();
  });
});

describe('createDragTracker', () => {
  it('cộng dồn delta, gọi một lần mỗi frame, xả khi thả', () => {
    const el = document.createElement('div');
    let frame: (() => void) | null = null;
    const onMove = vi.fn();
    const t = createDragTracker(el, { onMove, schedule: (cb) => ((frame = cb), 1), cancelSchedule: () => {} });
    const ev = (type: string, x: number) => new PointerEvent(type, { pointerId: 1, clientX: x, clientY: 0 });
    t.start(ev('pointerdown', 0));
    el.dispatchEvent(ev('pointermove', 3));
    el.dispatchEvent(ev('pointermove', 7));
    frame!();
    expect(onMove).toHaveBeenLastCalledWith(7, 0);
    el.dispatchEvent(ev('pointermove', 9));
    el.dispatchEvent(ev('pointerup', 9));
    expect(onMove).toHaveBeenLastCalledWith(2, 0);
    expect(onMove).toHaveBeenCalledTimes(2);
  });
});
ts

#So với thư viện và chuẩn web

  • scheduler.postTask(fn, { priority }) và scheduler.yield(): có ở Chrome và Firefox, chưa có ở Safari (tính tới 10/2026). scheduler.yield() còn giữ ưu tiên cho phần tiếp theo, tốt hơn mọi mẹo message.
  • React Scheduler: dùng MessageChannel để đánh thức, và tự cắt lượt sau khoảng 5ms để nhường trình duyệt. Đó là cách giải đúng vấn đề "rút cạn".
  • Polyfill setimmediate (YuzuJS): tổ tiên của bản Facebook, cùng thứ tự fallback; cũng rút cạn theo handle.
  • PointerEvent.getCoalescedEvents() có ở mọi trình duyệt chính; getPredictedEvents() chưa có ở Safari (tính tới 10/2026).
  • Thư viện kéo thả (dnd-kit, @use-gesture) đều gom theo rAF tương tự tracker.

Bài này thuộc series Học từ mã nguồn Facebook (106 bài, đọc theo thứ tự).

Xem nhanh danh sách bài trong series

Phần 1

Phần 2

Phần 3

Phần 4–6

Phần 7–10

Phần 11–15

Code + demo: examples/facebook-patterns · Mở trên StackBlitz