/
Nspection
/
rules-manager-mcp
Обзор
Документация
Войти
/
Nspection
/
rules-manager-mcp
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
dev
node_modules/hono/dist/utils/concurrent.js
39 строк
853 B
Buglov Evgeny
Первый коммит
27 фев 2026, 21:12
27 фев 2026, 21:12
e51dee3
Код
Авторство
О чём код?
// src/utils/concurrent.ts var DEFAULT_CONCURRENCY = 1024; var createPool = ({ concurrency, interval } = {}) => { concurrency ||= DEFAULT_CONCURRENCY; if (concurrency === Infinity) { return { run: async (fn) => fn() }; } const pool = /* @__PURE__ */ new Set(); const run = async (fn, promise, resolve) => { if (pool.size >= concurrency) { promise ||= new Promise((r) => resolve = r); setTimeout(() => run(fn, promise, resolve)); return promise; } const marker = {}; pool.add(marker); const result = await fn(); if (interval) { setTimeout(() => pool.delete(marker), interval); } else { pool.delete(marker); } if (resolve) { resolve(result); return promise; } else { return result; } }; return { run }; }; export { createPool };