We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aff1716 commit b0bc571Copy full SHA for b0bc571
lib/priorityQueue.js
@@ -28,6 +28,7 @@ import Heap from './internal/Heap';
28
export default function(worker, concurrency) {
29
// Start with a normal queue
30
var q = queue(worker, concurrency);
31
+ var processingScheduled = false;
32
33
q._tasks = new Heap();
34
@@ -55,7 +56,13 @@ export default function(worker, concurrency) {
55
56
q._tasks.push(item);
57
}
58
- setImmediate(q.process);
59
+ if (!processingScheduled) {
60
+ processingScheduled = true;
61
+ setImmediate(() => {
62
+ processingScheduled = false;
63
+ q.process();
64
+ });
65
+ }
66
};
67
68
// Remove unshift function
0 commit comments