Merge pull request #62 from jdanford/fix-acquire-max-pending

Use `maxPending` value from options in `acquire()` method
rogierschouten · Dec 22, 2023 · 66b98e1 · 66b98e1
2 parents cf98f50 + 59f7864
commit 66b98e1
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/index.js b/lib/index.js
@@ -182,6 +182,8 @@ AsyncLock.prototype.acquire = function (key, fn, cb, opts) {
 		exec = process.domain.bind(exec);
 	}
 
+	var maxPending = opts.maxPending || self.maxPending;
+
 	if (!self.queues[key]) {
 		self.queues[key] = [];
 		exec(true);
@@ -191,7 +193,7 @@ AsyncLock.prototype.acquire = function (key, fn, cb, opts) {
 		// Since lock is re-enterable
 		exec(false);
 	}
-	else if (self.queues[key].length >= self.maxPending) {
+	else if (self.queues[key].length >= maxPending) {
 		done(false, new Error('Too many pending tasks in queue ' + key));
 	}
 	else {