diff options
| author | Suguru Motegi <suguru.motegi@gmail.com> | 2016-04-26 20:27:11 -0700 |
|---|---|---|
| committer | Suguru Motegi <suguru.motegi@gmail.com> | 2016-04-26 20:27:11 -0700 |
| commit | d18000b71d9c2a7d61b9ff9621513f2b0b6c3122 (patch) | |
| tree | eae6ab1f4f352af491d1b581600349ae3741fb3e | |
| parent | 1114e65d1e58abcf420d2f4cbb8ea413ded49859 (diff) | |
| download | async-d18000b71d9c2a7d61b9ff9621513f2b0b6c3122.tar.gz | |
fix `priorityQueue`
| -rw-r--r-- | lib/priorityQueue.js | 6 | ||||
| -rw-r--r-- | mocha_test/priorityQueue.js | 3 |
2 files changed, 0 insertions, 9 deletions
diff --git a/lib/priorityQueue.js b/lib/priorityQueue.js index a33f2f5..4c29596 100644 --- a/lib/priorityQueue.js +++ b/lib/priorityQueue.js @@ -73,12 +73,6 @@ export default function(worker, concurrency) { q.tasks.splice(_binarySearch(q.tasks, item, _compareTasks) + 1, 0, item); - if (q.tasks.length === q.concurrency) { - q.saturated(); - } - if (q.tasks.length <= (q.concurrency - q.buffer) ) { - q.unsaturated(); - } setImmediate(q.process); }); } diff --git a/mocha_test/priorityQueue.js b/mocha_test/priorityQueue.js index fa5cfce..6ac3d15 100644 --- a/mocha_test/priorityQueue.js +++ b/mocha_test/priorityQueue.js @@ -148,9 +148,6 @@ describe('priorityQueue', function() { expect(calls.indexOf('unsaturated')).to.be.above(-1); setTimeout(function() { expect(calls).eql([ - 'unsaturated', - 'unsaturated', - 'unsaturated', 'process foo4', 'process foo3', 'process foo2', |