Как ограничивать количество параллельных async-задач?

Ограничение параллельных async-задач

Когда нужно выполнить много асинхронных операций (например, запросы к API), запуск всех одновременно может перегрузить сеть или сервер. Для контроля используют механизм ограничения параллельности (concurrency limit).

Как это работает

Создаётся очередь задач и пул из N одновременно выполняемых промисов. Когда один промис завершается, из очереди берётся следующий. Это похоже на работу thread pool в других языках.

Пример реализации

async function asyncPool(limit, tasks) {
  const results = [];
  const executing = new Set();

  for (const task of tasks) {
    const p = Promise.resolve().then(() => task());
    results.push(p);
    executing.add(p);

    const clean = () => executing.delete(p);
    p.then(clean, clean);

    if (executing.size >= limit) {
      await Promise.race(executing);
    }
  }

  return Promise.all(results);
}

// Использование
const tasks = [1,2,3,4,5].map(i => () => fetch(`/api/${i}`));
await asyncPool(2, tasks);

Где применяется

• Загрузка множества файлов
• Пакетные запросы к API с rate limiting
• Обработка данных в потоках

Вывод: Ограничение параллельности — важный паттерн для стабильности и производительности приложений, особенно при работе с внешними ресурсами или ограниченными системами.