Promise queue with concurrency control. Same API as p-queue, but ships both ESM and CJS with zero dependencies.
import { PQueue } from "tiny-pqueue"; const queue = new PQueue({ concurrency: 5 }); await queue.add(() => fetch(url)); await queue.onIdle();
~3.2 KB gzipped. Zero dependencies. Priority support, pause/resume, events, timeouts.
Demo built with remotion-readme-kit
npm install tiny-pqueue
import { PQueue } from "tiny-pqueue"; const queue = new PQueue({ concurrency: 3 }); const result = await queue.add(() => fetchUser(1)); const batch = await queue.addAll([ () => fetchUser(2), () => fetchUser(3), () => fetchUser(4), ]); await queue.onIdle();
const queue = new PQueue({ concurrency: 1 }); queue.add(lowPriorityWork, { priority: 0 }); queue.add(highPriorityWork, { priority: 10 }); // runs first
queue.pause(); queue.add(() => doWork()); // queued but won't run queue.start(); // now it runs await queue.onIdle();
const queue = new PQueue({ concurrency: 2, timeout: 5000, throwOnTimeout: true, }); // throws if task takes longer than 5 seconds await queue.add(() => slowOperation());
queue.on("active", () => console.log(`Running: ${queue.pending}`)); queue.on("idle", () => console.log("All done")); queue.on("error", (err) => console.error(err));
await queue.onEmpty(); // queue drained (tasks may still run) await queue.onIdle(); // everything finished await queue.onSizeLessThan(5); // queue drops below 5
p-queue v8+ is ESM-only. If you require("p-queue") in a CommonJS project, you get ERR_REQUIRE_ESM. tiny-queue works with both import and require().
p-queue |
tiny-queue |
|
|---|---|---|
| CJS support | v6 only (v7+ ESM-only) | ESM + CJS |
| Dependencies | eventemitter3, p-timeout |
0 |
| TypeScript | separate @types | native |
| Export | default | named |
- import PQueue from "p-queue"; + import { PQueue } from "tiny-pqueue";
One line. Everything else stays the same.
concurrency- max parallel tasks (default:Infinity)autoStart- start processing immediately (default:true)timeout- per-task timeout in msthrowOnTimeout- throw on timeout instead of resolving undefined (default:false)
Add a task. Returns a promise with the result. Options: priority (higher = sooner, default 0), signal (AbortSignal).
Add multiple tasks. Returns Promise<T[]>.
Pause or resume processing.
Remove all pending tasks.
Wait for queue state changes.
Events: active, idle, add, next, completed, error.
Inspect and control the queue at runtime.
Drop-in replacements for sindresorhus async utilities. All ship ESM + CJS with zero dependencies.
| Package | Replaces | What it does |
|---|---|---|
| tiny-limit | p-limit | Concurrency limiter |
| tiny-map | p-map | Concurrent map with order |
| tiny-retry | p-retry | Retry with exponential backoff |
| tiny-queue | p-queue | Priority task queue |
| tiny-ms | ms | Parse/format durations |
| tiny-escape | escape-string-regexp | Escape regex chars |
Want all async utilities in one import? Use tiny-pasync.
If this saved you from ERR_REQUIRE_ESM, star the repo or open an issue if something breaks.
README built with README Builder