Lorem Ipsum MCP Server

/** * @since 2.0.0 */ import type { Effect } from "./Effect.js" import type { RuntimeFiber } from "./Fiber.js" import type { FiberRef } from "./FiberRef.js" import { dual } from "./Function.js" import { globalValue } from "./GlobalValue.js" import * as core from "./internal/core.js" /** * @since 2.0.0 * @category models */ export type Task = () => void /** * @since 2.0.0 * @category models */ export interface Scheduler { shouldYield(fiber: RuntimeFiber<unknown, unknown>): number | false scheduleTask(task: Task, priority: number): void } /** * @since 2.0.0 * @category utils */ export class PriorityBuckets<in out T = Task> { /** * @since 2.0.0 */ public buckets: Array<[number, Array<T>]> = [] /** * @since 2.0.0 */ scheduleTask(task: T, priority: number) { const length = this.buckets.length let bucket: [number, Array<T>] | undefined = undefined let index = 0 for (; index < length; index++) { if (this.buckets[index][0] <= priority) { bucket = this.buckets[index] } else { break } } if (bucket && bucket[0] === priority) { bucket[1].push(task) } else if (index === length) { this.buckets.push([priority, [task]]) } else { this.buckets.splice(index, 0, [priority, [task]]) } } } /** * @since 2.0.0 * @category constructors */ export class MixedScheduler implements Scheduler { /** * @since 2.0.0 */ running = false /** * @since 2.0.0 */ tasks = new PriorityBuckets() constructor( /** * @since 2.0.0 */ readonly maxNextTickBeforeTimer: number ) {} /** * @since 2.0.0 */ private starveInternal(depth: number) { const tasks = this.tasks.buckets this.tasks.buckets = [] for (const [_, toRun] of tasks) { for (let i = 0; i < toRun.length; i++) { toRun[i]() } } if (this.tasks.buckets.length === 0) { this.running = false } else { this.starve(depth) } } /** * @since 2.0.0 */ private starve(depth = 0) { if (depth >= this.maxNextTickBeforeTimer) { setTimeout(() => this.starveInternal(0), 0) } else { Promise.resolve(void 0).then(() => this.starveInternal(depth + 1)) } } /** * @since 2.0.0 */ shouldYield(fiber: RuntimeFiber<unknown, unknown>): number | false { return fiber.currentOpCount > fiber.getFiberRef(core.currentMaxOpsBeforeYield) ? fiber.getFiberRef(core.currentSchedulingPriority) : false } /** * @since 2.0.0 */ scheduleTask(task: Task, priority: number) { this.tasks.scheduleTask(task, priority) if (!this.running) { this.running = true this.starve() } } } /** * @since 2.0.0 * @category schedulers */ export const defaultScheduler: Scheduler = globalValue( Symbol.for("effect/Scheduler/defaultScheduler"), () => new MixedScheduler(2048) ) /** * @since 2.0.0 * @category constructors */ export class SyncScheduler implements Scheduler { /** * @since 2.0.0 */ tasks = new PriorityBuckets() /** * @since 2.0.0 */ deferred = false /** * @since 2.0.0 */ scheduleTask(task: Task, priority: number) { if (this.deferred) { defaultScheduler.scheduleTask(task, priority) } else { this.tasks.scheduleTask(task, priority) } } /** * @since 2.0.0 */ shouldYield(fiber: RuntimeFiber<unknown, unknown>): number | false { return fiber.currentOpCount > fiber.getFiberRef(core.currentMaxOpsBeforeYield) ? fiber.getFiberRef(core.currentSchedulingPriority) : false } /** * @since 2.0.0 */ flush() { while (this.tasks.buckets.length > 0) { const tasks = this.tasks.buckets this.tasks.buckets = [] for (const [_, toRun] of tasks) { for (let i = 0; i < toRun.length; i++) { toRun[i]() } } } this.deferred = true } } /** * @since 2.0.0 * @category constructors */ export class ControlledScheduler implements Scheduler { /** * @since 2.0.0 */ tasks = new PriorityBuckets() /** * @since 2.0.0 */ deferred = false /** * @since 2.0.0 */ scheduleTask(task: Task, priority: number) { if (this.deferred) { defaultScheduler.scheduleTask(task, priority) } else { this.tasks.scheduleTask(task, priority) } } /** * @since 2.0.0 */ shouldYield(fiber: RuntimeFiber<unknown, unknown>): number | false { return fiber.currentOpCount > fiber.getFiberRef(core.currentMaxOpsBeforeYield) ? fiber.getFiberRef(core.currentSchedulingPriority) : false } /** * @since 2.0.0 */ step() { const tasks = this.tasks.buckets this.tasks.buckets = [] for (const [_, toRun] of tasks) { for (let i = 0; i < toRun.length; i++) { toRun[i]() } } } } /** * @since 2.0.0 * @category constructors */ export const makeMatrix = (...record: Array<[number, Scheduler]>): Scheduler => { const index = record.sort(([p0], [p1]) => p0 < p1 ? -1 : p0 > p1 ? 1 : 0) return { shouldYield(fiber) { for (const scheduler of record) { const priority = scheduler[1].shouldYield(fiber) if (priority !== false) { return priority } } return false }, scheduleTask(task, priority) { let scheduler: Scheduler | undefined = undefined for (const i of index) { if (priority >= i[0]) { scheduler = i[1] } else { return (scheduler ?? defaultScheduler).scheduleTask(task, priority) } } return (scheduler ?? defaultScheduler).scheduleTask(task, priority) } } } /** * @since 2.0.0 * @category utilities */ export const defaultShouldYield: Scheduler["shouldYield"] = (fiber) => { return fiber.currentOpCount > fiber.getFiberRef(core.currentMaxOpsBeforeYield) ? fiber.getFiberRef(core.currentSchedulingPriority) : false } /** * @since 2.0.0 * @category constructors */ export const make = ( scheduleTask: Scheduler["scheduleTask"], shouldYield: Scheduler["shouldYield"] = defaultShouldYield ): Scheduler => ({ scheduleTask, shouldYield }) /** * @since 2.0.0 * @category constructors */ export const makeBatched = ( callback: (runBatch: () => void) => void, shouldYield: Scheduler["shouldYield"] = defaultShouldYield ) => { let running = false const tasks = new PriorityBuckets() const starveInternal = () => { const tasksToRun = tasks.buckets tasks.buckets = [] for (const [_, toRun] of tasksToRun) { for (let i = 0; i < toRun.length; i++) { toRun[i]() } } if (tasks.buckets.length === 0) { running = false } else { starve() } } const starve = () => callback(starveInternal) return make((task, priority) => { tasks.scheduleTask(task, priority) if (!running) { running = true starve() } }, shouldYield) } /** * @since 2.0.0 * @category constructors */ export const timer = (ms: number, shouldYield: Scheduler["shouldYield"] = defaultShouldYield) => make((task) => setTimeout(task, ms), shouldYield) /** * @since 2.0.0 * @category constructors */ export const timerBatched = (ms: number, shouldYield: Scheduler["shouldYield"] = defaultShouldYield) => makeBatched((task) => setTimeout(task, ms), shouldYield) /** @internal */ export const currentScheduler: FiberRef<Scheduler> = globalValue( Symbol.for("effect/FiberRef/currentScheduler"), () => core.fiberRefUnsafeMake(defaultScheduler) ) /** @internal */ export const withScheduler = dual< /** @internal */ (scheduler: Scheduler) => <A, E, R>(self: Effect<A, E, R>) => Effect<A, E, R>, /** @internal */ <A, E, R>(self: Effect<A, E, R>, scheduler: Scheduler) => Effect<A, E, R> >(2, (self, scheduler) => core.fiberRefLocally(self, currentScheduler, scheduler))