From 9bce51f651aad297ef9eb6df832bfdaf1de05d84 Mon Sep 17 00:00:00 2001
From: WXL <wl_5969728@163.com>
Date: 星期三, 22 四月 2026 14:27:54 +0800
Subject: [PATCH] 青岛推送
---
node_modules/webpack/lib/util/AsyncQueue.js | 20 ++++++++++++++++++++
1 files changed, 20 insertions(+), 0 deletions(-)
diff --git a/node_modules/webpack/lib/util/AsyncQueue.js b/node_modules/webpack/lib/util/AsyncQueue.js
index 3005615..e4bc274 100644
--- a/node_modules/webpack/lib/util/AsyncQueue.js
+++ b/node_modules/webpack/lib/util/AsyncQueue.js
@@ -17,6 +17,7 @@
let inHandleResult = 0;
/**
+ * Defines the callback callback.
* @template T
* @callback Callback
* @param {(WebpackError | null)=} err
@@ -25,12 +26,14 @@
*/
/**
+ * Represents AsyncQueueEntry.
* @template T
* @template K
* @template R
*/
class AsyncQueueEntry {
/**
+ * Creates an instance of AsyncQueueEntry.
* @param {T} item the item
* @param {Callback<R>} callback the callback
*/
@@ -50,22 +53,26 @@
}
/**
+ * Defines the get key type used by this module.
* @template T, K
* @typedef {(item: T) => K} getKey
*/
/**
+ * Defines the processor type used by this module.
* @template T, R
* @typedef {(item: T, callback: Callback<R>) => void} Processor
*/
/**
+ * Represents AsyncQueue.
* @template T
* @template K
* @template R
*/
class AsyncQueue {
/**
+ * Creates an instance of AsyncQueue.
* @param {object} options options object
* @param {string=} options.name name of the queue
* @param {number=} options.parallelism how many items should be processed at once
@@ -119,6 +126,7 @@
}
/**
+ * Returns context of execution.
* @returns {string} context of execution
*/
getContext() {
@@ -126,6 +134,7 @@
}
/**
+ * Updates context using the provided value.
* @param {string} value context of execution
*/
setContext(value) {
@@ -133,6 +142,7 @@
}
/**
+ * Processes the provided item.
* @param {T} item an item
* @param {Callback<R>} callback callback function
* @returns {void}
@@ -185,6 +195,7 @@
}
/**
+ * Processes the provided item.
* @param {T} item an item
* @returns {void}
*/
@@ -225,6 +236,7 @@
}
/**
+ * Describes how this stop operation behaves.
* @returns {void}
*/
stop() {
@@ -245,6 +257,7 @@
}
/**
+ * Increase parallelism.
* @returns {void}
*/
increaseParallelism() {
@@ -258,6 +271,7 @@
}
/**
+ * Decrease parallelism.
* @returns {void}
*/
decreaseParallelism() {
@@ -266,6 +280,7 @@
}
/**
+ * Checks whether this async queue is processing.
* @param {T} item an item
* @returns {boolean} true, if the item is currently being processed
*/
@@ -276,6 +291,7 @@
}
/**
+ * Checks whether this async queue is queued.
* @param {T} item an item
* @returns {boolean} true, if the item is currently queued
*/
@@ -286,6 +302,7 @@
}
/**
+ * Checks whether this async queue is done.
* @param {T} item an item
* @returns {boolean} true, if the item is currently queued
*/
@@ -296,6 +313,7 @@
}
/**
+ * Describes how this ensure processing operation behaves.
* @returns {void}
*/
_ensureProcessing() {
@@ -324,6 +342,7 @@
}
/**
+ * Processes the provided entry.
* @param {AsyncQueueEntry<T, K, R>} entry the entry
* @returns {void}
*/
@@ -351,6 +370,7 @@
}
/**
+ * Processes the provided entry.
* @param {AsyncQueueEntry<T, K, R>} entry the entry
* @param {(WebpackError | null)=} err error, if any
* @param {(R | null)=} result result, if any
--
Gitblit v1.9.3