Class MicroSchedulerDefault

packages/effect/src/Micro.ts:1777–1826

 * @category scheduler
 */
export class MicroSchedulerDefault implements MicroScheduler {
  private tasks: Array<() => void> = []
  private running = false

  /**
   * @since 3.5.9
   */
  scheduleTask(task: () => void, _priority: number) {
    this.tasks.push(task)
    if (!this.running) {
      this.running = true
      setImmediate(this.afterScheduled)
    }
  }

  /**
   * @since 3.5.9
   */
  afterScheduled = () => {
    this.running = false
    this.runTasks()
  }

  /**
   * @since 3.5.9
   */
  runTasks() {
    const tasks = this.tasks
    this.tasks = []
    for (let i = 0, len = tasks.length; i < len; i++) {
      tasks[i]()
    }
  }

  /**
   * @since 3.5.9
   */
  shouldYield(fiber: MicroFiber<unknown, unknown>) {
    return fiber.currentOpCount >= fiber.getRef(MaxOpsBeforeYield)
  }

  /**
   * @since 3.5.9
   */
  flush() {
    while (this.tasks.length > 0) {
      this.runTasks()
    }
  }
}

/**
 * Access the given `Context.Tag` from the environment.