如何实现一个可控频率的函数执行任务队列？-js教程-PHP中文网

可控频率任务队列需控制触发节奏与执行顺序，基于节流思想实现带时间窗口的调度器，支持动态调频、暂停/恢复及任务取消。

如何实现一个可控频率的函数执行任务队列？

要实现一个可控频率的函数执行任务队列，核心是控制任务的**触发节奏**和**执行顺序**，而不是简单地用 setTimeout 或 setInterval 堆砌。关键在于：任务入队后不立即执行，而是按设定的最小间隔（如每 200ms 最多执行一次）排队调度，同时支持动态调整频率、暂停/恢复、取消待执行任务。

用节流（throttle）思想构建队列调度器

这不是传统“先进先出”的纯队列，而是带时间窗口的调度器。每次添加任务时，判断距离上一次执行是否已过设定间隔；若未到，则暂存任务，等下次“窗口打开”时统一执行（或只执行最新一个，取决于策略）。

固定窗口 + 执行最新任务：适合防抖场景（如搜索框输入），只保留最后一次请求
固定窗口 + 执行队首任务：适合轮询类任务，保证每个任务至少被执行一次（可配最大等待时长）
动态频率调整：暴露 setRate(ms) 方法，更新内部间隔阈值，后续调度按新频率生效

简易可运行实现（基于 Promise 队列）

以下是一个轻量、可暂停、可调频的任务队列示例：

炉米Lumi

一款面向AI模型和生成式创作的模型社区与训练平台，方便用户探索模型资源并参与相关模型应用和创作。

下载

class FrequencyQueue {
  constructor(minInterval = 1000) {
    this.minInterval = minInterval;
    this.tasks = [];
    this.lastExecTime = 0;
    this.isRunning = true;
    this.timer = null;
  }
<p>push(fn, ...args) {
return new Promise((resolve) => {
this.tasks.push({ fn, args, resolve });
this._schedule();
});
}</p><p>_schedule() {
if (!this.isRunning || this.timer || this.tasks.length === 0) return;</p><pre class="brush:php;toolbar:false;">const now = Date.now();
const nextAllowed = this.lastExecTime + this.minInterval;
const delay = Math.max(0, nextAllowed - now);

this.timer = setTimeout(() => {
  const task = this.tasks.shift();
  if (task) {
    try {
      const result = task.fn(...task.args);
      task.resolve(Promise.resolve(result));
    } catch (e) {
      task.resolve(Promise.reject(e));
    }
    this.lastExecTime = Date.now();
  }
  this.timer = null;
  this._schedule(); // 继续调度下一个
}, delay);

}

setRate(ms) { this.minInterval = Math.max(0, ms); }

pause() { this.isRunning = false; if (this.timer) { clearTimeout(this.timer); this.timer = null; } }

resume() { this.isRunning = true; this._schedule(); }

clear() { this.tasks = []; if (this.timer) { clearTimeout(this.timer); this.timer = null; } } }

// 使用示例： const q = new FrequencyQueue(500); // 每 500ms 最多执行一个任务

q.push(console.log, 'task 1').then(() => console.log('done 1')); q.push(console.log, 'task 2').then(() => console.log('done 2')); q.push(console.log, 'task 3').then(() => console.log('done 3'));

// 运行中动态降频 setTimeout(() => q.setRate(1200), 2000);

进阶要点：避免常见陷阱

时间精度问题：Date.now() 和 setTimeout 本身有延迟，高频场景建议用 requestIdleCallback 或 queueMicrotask 做微调，但注意兼容性
错误隔离：单个任务异常不应阻塞整个队列，需在 try/catch 中包裹执行，并确保 resolve/reject 总被调用
内存泄漏风险：长期运行的队列需提供 clear() 或自动清理超时任务（例如设置 maxWait: 5000，入队超 5 秒未执行则 reject）
与事件循环协同：若任务本身是异步（如 API 调用），应在 fn 返回 Promise 后再触发下一次调度，而非仅看“开始执行”时间