lint compliance
This commit is contained in:
parent
2d6626234b
commit
2345323f0d
|
@ -128,7 +128,7 @@ module.exports = function (max) {
|
||||||
// run as many new jobs as are allowed.
|
// run as many new jobs as are allowed.
|
||||||
var next = function () {
|
var next = function () {
|
||||||
// array.some skips over bare indexes in sparse arrays
|
// array.some skips over bare indexes in sparse arrays
|
||||||
var pending = jobs.some(function (bag, priority) {
|
var pending = jobs.some(function (bag /*, priority*/) {
|
||||||
if (!bag || typeof(bag) !== 'object') { return; }
|
if (!bag || typeof(bag) !== 'object') { return; }
|
||||||
// a bag is a map of jobs for any particular degree of priority
|
// a bag is a map of jobs for any particular degree of priority
|
||||||
// iterate over jobs in the bag until you're out of 'workers'
|
// iterate over jobs in the bag until you're out of 'workers'
|
||||||
|
@ -202,7 +202,7 @@ module.exports = function (max) {
|
||||||
};
|
};
|
||||||
|
|
||||||
var started = false;
|
var started = false;
|
||||||
var start = plan.start = function () {
|
plan.start = function () {
|
||||||
// don't allow multiple starts
|
// don't allow multiple starts
|
||||||
// even though it should work, it's simpler not to.
|
// even though it should work, it's simpler not to.
|
||||||
if (started) { return plan; }
|
if (started) { return plan; }
|
||||||
|
|
|
@ -1,3 +1,4 @@
|
||||||
|
/*jshint esversion: 6 */
|
||||||
const Plan = require("../../lib/plan");
|
const Plan = require("../../lib/plan");
|
||||||
|
|
||||||
var rand_delay = function (f) {
|
var rand_delay = function (f) {
|
||||||
|
@ -5,7 +6,7 @@ var rand_delay = function (f) {
|
||||||
};
|
};
|
||||||
|
|
||||||
var plan = Plan(6).job(1, function (next) {
|
var plan = Plan(6).job(1, function (next) {
|
||||||
[1,2,3,4,5,6,7,8,9,10,11,12].forEach(function (n, i) {
|
[1,2,3,4,5,6,7,8,9,10,11,12].forEach(function (n) {
|
||||||
plan.job(0, function (next) {
|
plan.job(0, function (next) {
|
||||||
rand_delay(function () {
|
rand_delay(function () {
|
||||||
console.log("finishing job %s", n);
|
console.log("finishing job %s", n);
|
||||||
|
@ -23,7 +24,7 @@ var plan = Plan(6).job(1, function (next) {
|
||||||
200,
|
200,
|
||||||
300,
|
300,
|
||||||
400
|
400
|
||||||
].forEach(function (n, i) {
|
].forEach(function (n) {
|
||||||
plan.job(3, function (next) {
|
plan.job(3, function (next) {
|
||||||
rand_delay(function () {
|
rand_delay(function () {
|
||||||
console.log("finishing job %s", n);
|
console.log("finishing job %s", n);
|
||||||
|
|
Loading…
Reference in New Issue