createScheduler

Стабильный · с 0.1.0

Создаёт планировщик диспатча, которым рантайм пользуется внутри. Две встроенные стратегии — 'microtask' и 'sync' — закрывают почти любые реальные потребности; createScheduler доступен для кастомной композиции рантайма, низкоуровневых тестов и бенчмарков.

Microtask-планировщик батчит поставленные в очередь задачи и осушает их в queueMicrotask. Sync-планировщик запускает задачи немедленно, в стеке вызывающей стороны.

Импорт

import { createScheduler } from '@triggery/core';

Сигнатура

function createScheduler(strategy: SchedulerStrategy): SchedulerImpl;

type SchedulerStrategy = 'sync' | 'microtask';

type SchedulerImpl = {
  enqueue(task: () => void): void;
  flush(): void;
};

Параметры

Параметр	Тип	Описание
`strategy`	`'sync' \| 'microtask'`	Политика диспатча.

Возвращает

SchedulerImpl:

Метод	Описание
`enqueue(task)`	Поставить thunk в очередь. Microtask: батчит до следующего осушения микротасок. Sync: запускает немедленно.
`flush()`	Осушить отложенные задачи прямо сейчас. Для тестов и `fireSync`. Sync-планировщик очередь не держит, поэтому его `flush` — no-op.

Примеры

Microtask-батчинг

import { createSchedulerfunction createScheduler(strategy: SchedulerStrategy): SchedulerImpl } from '@triggery/core';

const schedconst sched: SchedulerImpl = createSchedulerfunction createScheduler(strategy: SchedulerStrategy): SchedulerImpl('microtask');
const logconst log: number[]: number[] = [];

schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => logconst log: number[].pushArray<number>.push(...items: number[]): numberAppends new elements to the end of an array, and returns the new length of the array.
@paramitems New elements to add to the array.(1));
schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => logconst log: number[].pushArray<number>.push(...items: number[]): numberAppends new elements to the end of an array, and returns the new length of the array.
@paramitems New elements to add to the array.(2));
schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => logconst log: number[].pushArray<number>.push(...items: number[]): numberAppends new elements to the end of an array, and returns the new length of the array.
@paramitems New elements to add to the array.(3));

// At this synchronous point, nothing has run yet.
consolevar console: Console.logConsole.log(...data: any[]): voidThe **`console.log()`** static method outputs a message to the console.

[MDN Reference](https://developer.mozilla.org/docs/Web/API/console/log_static)('queued', logconst log: number[]); // []

await Promisevar Promise: PromiseConstructorRepresents the completion of an asynchronous operation.resolvePromiseConstructor.resolve(): Promise<void> (+2 overloads)Creates a new resolved promise.
@returnsA resolved promise.(); // drain microtasks
consolevar console: Console.logConsole.log(...data: any[]): voidThe **`console.log()`** static method outputs a message to the console.

[MDN Reference](https://developer.mozilla.org/docs/Web/API/console/log_static)('drained', logconst log: number[]); // [1, 2, 3]

Синхронный диспатч

import { createSchedulerfunction createScheduler(strategy: SchedulerStrategy): SchedulerImpl } from '@triggery/core';

const schedconst sched: SchedulerImpl = createSchedulerfunction createScheduler(strategy: SchedulerStrategy): SchedulerImpl('sync');
const logconst log: number[]: number[] = [];

schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => logconst log: number[].pushArray<number>.push(...items: number[]): numberAppends new elements to the end of an array, and returns the new length of the array.
@paramitems New elements to add to the array.(1));
schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => logconst log: number[].pushArray<number>.push(...items: number[]): numberAppends new elements to the end of an array, and returns the new length of the array.
@paramitems New elements to add to the array.(2));

// Already executed inline.
consolevar console: Console.logConsole.log(...data: any[]): voidThe **`console.log()`** static method outputs a message to the console.

[MDN Reference](https://developer.mozilla.org/docs/Web/API/console/log_static)(logconst log: number[]); // [1, 2]

Изоляция ошибок в microtask-режиме

import { createSchedulerfunction createScheduler(strategy: SchedulerStrategy): SchedulerImpl } from '@triggery/core';

const schedconst sched: SchedulerImpl = createSchedulerfunction createScheduler(strategy: SchedulerStrategy): SchedulerImpl('microtask');

schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => {
  throw new Errorvar Error: ErrorConstructor
new (message?: string, options?: ErrorOptions) => Error (+1 overload)('oops');
});
schedconst sched: SchedulerImpl.enqueuefunction enqueue(task: Task): void(() => {
  consolevar console: Console.logConsole.log(...data: any[]): voidThe **`console.log()`** static method outputs a message to the console.

[MDN Reference](https://developer.mozilla.org/docs/Web/API/console/log_static)('still runs');
});

await Promisevar Promise: PromiseConstructorRepresents the completion of an asynchronous operation.resolvePromiseConstructor.resolve(): Promise<void> (+2 overloads)Creates a new resolved promise.
@returnsA resolved promise.();
// Output: "[triggery] scheduler task failed: Error: oops"
// Output: "still runs"

Замечания

См. также

createRuntime Рантайм автоматически выбирает планировщик per-trigger.

createFakeScheduler Планировщик с виртуальным временем для тестов.

Руководство по планированию Microtask vs sync — когда что выбирать.

Стратегии конкурентности Как асинхронные обработчики переплетаются по каждой стратегии.