🎩 You're Invited:Meet the Socket team at Black Hat in Las Vegas, August 3-6.RSVP →
Sign In

p-queue

Package Overview
Dependencies
Maintainers
1
Versions
56
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

p-queue - npm Package Compare versions

Comparing version
9.3.2
 to
9.3.3
+20
-21
dist/index.js

@@ -15,5 +15,9 @@ import { EventEmitter } from 'eventemitter3';

#interval;
/*
Timestamp when the current interval window ends. Kept accurate at every window transition: `#initializeIntervalIfNeeded` sets it when a window starts and `#onInterval` advances it as the recurring timer rolls into each new window. This is the source of truth for whether a task added after the queue goes idle belongs to a fresh window, so it must not go stale.
*/
#intervalEnd = 0;
#lastExecutionTime = 0;
// Recurring timer that drives windows while the queue is actively processing. Absent (`undefined`) once the queue goes idle.
#intervalId;
// One-shot timer used while idle to resume at the next window boundary, since `#intervalId` is cleared when idle.
#timeoutId;

@@ -179,22 +183,11 @@ #strict;

}
// Fixed window mode (original logic)
// Fixed window mode. While the recurring timer runs it already governs the windows, so pausing is only decided here when the queue is idle (the timer is absent) and we rely on `#intervalEnd`.
if (this.#intervalId === undefined) {
const delay = this.#intervalEnd - now;
if (delay < 0) {
// If the interval has expired while idle, check if we should enforce the interval
// from the last task execution. This ensures proper spacing between tasks even
// when the queue becomes empty and then new tasks are added.
if (this.#lastExecutionTime > 0) {
const timeSinceLastExecution = now - this.#lastExecutionTime;
if (timeSinceLastExecution < this.#interval) {
// Not enough time has passed since the last task execution
this.#createIntervalTimeout(this.#interval - timeSinceLastExecution);
return true;
}
}
// Enough time has passed or no previous execution, allow execution
this.#intervalCount = (this.#carryoverIntervalCount) ? this.#pending : 0;
// The interval expired while idle, so reset the count for the new window.
this.#intervalCount = this.#carryoverIntervalCount ? this.#pending : 0;
}
else {
// Act as the interval is pending
// Still inside the previous window; wait out the remaining time before starting the next task.
this.#createIntervalTimeout(delay);

@@ -254,7 +247,7 @@ return true;

}
this.emit('active');
job();
if (canInitializeInterval) {
this.#initializeIntervalIfNeeded();
}
this.emit('active');
job();
taskStarted = true;

@@ -281,4 +274,11 @@ }

if (!this.#strict) {
if (this.#intervalCount === 0 && this.#pending === 0 && this.#intervalId) {
this.#clearIntervalTimer();
// Only touch the recurring interval timer here. When resumed via a timeout instead, `#intervalId` is undefined and `#initializeIntervalIfNeeded` sets `#intervalEnd` right after.
if (this.#intervalId !== undefined) {
if (this.#intervalCount === 0 && this.#pending === 0) {
this.#clearIntervalTimer();
}
else {
// The recurring timer fired, starting a new window. Keep the boundary accurate so tasks added after the queue later goes idle are scheduled against the correct window.
this.#intervalEnd = Date.now() + this.#interval;
}
}

@@ -388,3 +388,2 @@ this.#intervalCount = this.#carryoverIntervalCount ? this.#pending : 0;

}
this.#lastExecutionTime = Date.now();
let operation = function_({ signal: options.signal });

@@ -391,0 +390,0 @@ if (options.timeout !== undefined) {

+1
-1
package.json
{
"name": "p-queue",
"version": "9.3.2",
"version": "9.3.3",
"description": "Promise queue with concurrency control",

@@ -5,0 +5,0 @@ "license": "MIT",