sindresorhus/p-queue
P Queue
p-queue 是一个 JavaScript Promise 队列和并发任务调度器，旨在限制活动异步操作的数量。它作为一个异步速率限制器和 Promise 生命周期管理器，以防止资源耗尽。
该项目以基于优先级的任务调度和令牌桶速率限制来控制执行频率而脱颖而出。它与用于任务取消的中止信号集成，并提供暂停、恢复和清除挂起操作的机制。
该工具涵盖了更广泛的流量管理能力，包括操作超时和并发限制。它还包括用于跟踪队列状态和挂起任务计数的监控原语，以及用于队列空闲的同步机制。
Features
- Asynchronous Task Schedulers - Provides a comprehensive system for dispatching and executing asynchronous tasks with priority and concurrency control.
- Task Queues - Provides a JavaScript promise queue for managing asynchronous tasks with strict concurrency limits.
- Token Bucket Implementations - Implements a token-bucket algorithm to cap the execution frequency of tasks over a fixed time window.
- Queue Priority Scheduling - Supports priority-based task scheduling to ensure critical operations are processed before lower-priority ones.
- Concurrency Semaphores - Uses semaphore-like logic to limit the number of active promises running simultaneously.
- Concurrent Task Limiters - Caps the number of parallel tasks executing to manage system resource consumption.
- Concurrent Task Schedulers - Ships a scheduler that controls the number of active promises and manages task priority and timeouts.
- Task Priority Execution - Implements priority levels for tasks to ensure that critical work is executed before lower-priority operations.
- Rate Limiters - Implements application-level rate limiting using token bucket and fixed window algorithms.
- Concurrency Limiting - Restricts the number of concurrent asynchronous operations to prevent system resource exhaustion.
- Queue Pause and Resume Controls - Allows the queue to be paused and resumed to synchronize background work with application state.
- Graceful Queue Draining - Provides a promise that resolves only after all active and pending tasks are fully processed.
- AbortSignal Cancellations - Integrates with AbortSignals to allow both pending and active tasks to be cancelled immediately.
- AbortSignal Integrations - Provides integration with standard browser AbortSignals to trigger the immediate removal or termination of pending tasks.
- Async Operation Timeouts - Provides the ability to set maximum execution durations for queued tasks to prevent hanging operations.
- Idle State Synchronization - Provides a synchronization mechanism that resolves promises only after the queue is empty and all active tasks finish.
- API Rate Limiting - Controls the frequency of outgoing network requests to comply with external API rate limits.
- Promise Lifecycle Managers - Manages the lifecycle of promises including the ability to pause, resume, and clear pending operations.
- Concurrency Control - Manage promise execution with concurrency control.
- Promise Utilities - Manages promise execution with concurrency control.
- Works with AVA - Listed in the “Works with AVA” section of the Awesome Ava awesome list.
