concurrent-tasks
Advanced tools
Comparing version 0.0.10 to 0.0.11
@@ -9,3 +9,3 @@ var _extends = Object.assign || function (target) { for (var i = 1; i < arguments.length; i++) { var source = arguments[i]; for (var key in source) { if (Object.prototype.hasOwnProperty.call(source, key)) { target[key] = source[key]; } } } return target; }; | ||
import { startCheckAndRun, startCheck, run } from './PrivateFunctions'; | ||
import { startCheckAndRun, runPending, startCheck } from './PrivateFunctions'; | ||
import log from './log'; | ||
@@ -54,2 +54,5 @@ | ||
_this.concurrency = assignNumber(concurrency, 3); | ||
if (_this.__working) { | ||
runPending.call(_this); | ||
} | ||
}; | ||
@@ -69,5 +72,3 @@ | ||
startCheck.call(_this); | ||
for (var i = 0; i < _this.concurrency; i++) { | ||
run.call(_this); | ||
} | ||
runPending.call(_this); | ||
return true; | ||
@@ -99,3 +100,3 @@ }; | ||
list: [].concat(_this.tasks.list, tasks), | ||
total: _this.tasks.list.length + tasks.length | ||
total: _this.tasks.total + tasks.length | ||
}); | ||
@@ -102,0 +103,0 @@ if (autoStart) { |
@@ -49,2 +49,10 @@ import { isFunction } from './util'; | ||
run.call(this); | ||
} | ||
export function runPending() { | ||
if (this.tasks.running < this.concurrency) { | ||
for (var i = this.tasks.running; i < this.concurrency; i++) { | ||
run.call(this); | ||
} | ||
} | ||
} |
@@ -63,2 +63,5 @@ 'use strict'; | ||
_this.concurrency = (0, _util.assignNumber)(concurrency, 3); | ||
if (_this.__working) { | ||
_PrivateFunctions.runPending.call(_this); | ||
} | ||
}; | ||
@@ -78,5 +81,3 @@ | ||
_PrivateFunctions.startCheck.call(_this); | ||
for (var i = 0; i < _this.concurrency; i++) { | ||
_PrivateFunctions.run.call(_this); | ||
} | ||
_PrivateFunctions.runPending.call(_this); | ||
return true; | ||
@@ -108,3 +109,3 @@ }; | ||
list: [].concat(_this.tasks.list, tasks), | ||
total: _this.tasks.list.length + tasks.length | ||
total: _this.tasks.total + tasks.length | ||
}); | ||
@@ -111,0 +112,0 @@ if (autoStart) { |
@@ -8,2 +8,3 @@ 'use strict'; | ||
exports.startCheckAndRun = startCheckAndRun; | ||
exports.runPending = runPending; | ||
@@ -58,2 +59,10 @@ var _util = require('./util'); | ||
run.call(this); | ||
} | ||
function runPending() { | ||
if (this.tasks.running < this.concurrency) { | ||
for (var i = this.tasks.running; i < this.concurrency; i++) { | ||
run.call(this); | ||
} | ||
} | ||
} |
{ | ||
"name": "concurrent-tasks", | ||
"version": "0.0.10", | ||
"version": "0.0.11", | ||
"description": "A simple task runner which will run tasks in parallel while maintaining limits.", | ||
@@ -5,0 +5,0 @@ "author": "Samrith Shankar", |
/*! | ||
* concurrent-tasks v0.0.10 - https://samrith-s.github.io/concurrent-tasks | ||
* concurrent-tasks v0.0.11 - https://samrith-s.github.io/concurrent-tasks | ||
* MIT Licensed | ||
@@ -199,2 +199,10 @@ */ | ||
} | ||
function runPending() { | ||
if (this.tasks.running < this.concurrency) { | ||
for (var i = this.tasks.running; i < this.concurrency; i++) { | ||
run.call(this); | ||
} | ||
} | ||
} | ||
// CONCATENATED MODULE: ./src/log.js | ||
@@ -265,2 +273,5 @@ var logs = { | ||
_this.concurrency = assignNumber(concurrency, 3); | ||
if (_this.__working) { | ||
runPending.call(_this); | ||
} | ||
}; | ||
@@ -280,5 +291,3 @@ | ||
startCheck.call(_this); | ||
for (var i = 0; i < _this.concurrency; i++) { | ||
run.call(_this); | ||
} | ||
runPending.call(_this); | ||
return true; | ||
@@ -310,3 +319,3 @@ }; | ||
list: [].concat(_this.tasks.list, tasks), | ||
total: _this.tasks.list.length + tasks.length | ||
total: _this.tasks.total + tasks.length | ||
}); | ||
@@ -313,0 +322,0 @@ if (autoStart) { |
/*! | ||
* concurrent-tasks v0.0.10 - https://samrith-s.github.io/concurrent-tasks | ||
* concurrent-tasks v0.0.11 - https://samrith-s.github.io/concurrent-tasks | ||
* MIT Licensed | ||
*/ | ||
!function(t,n){"object"==typeof exports&&"object"==typeof module?module.exports=n():"function"==typeof define&&define.amd?define([],n):"object"==typeof exports?exports.TaskRunner=n():t.TaskRunner=n()}(window,function(){return function(t){var n={};function r(e){if(n[e])return n[e].exports;var o=n[e]={i:e,l:!1,exports:{}};return t[e].call(o.exports,o,o.exports,r),o.l=!0,o.exports}return r.m=t,r.c=n,r.d=function(t,n,e){r.o(t,n)||Object.defineProperty(t,n,{enumerable:!0,get:e})},r.r=function(t){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(t,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(t,"__esModule",{value:!0})},r.t=function(t,n){if(1&n&&(t=r(t)),8&n)return t;if(4&n&&"object"==typeof t&&t&&t.__esModule)return t;var e=Object.create(null);if(r.r(e),Object.defineProperty(e,"default",{enumerable:!0,value:t}),2&n&&"string"!=typeof t)for(var o in t)r.d(e,o,function(n){return t[n]}.bind(null,o));return e},r.n=function(t){var n=t&&t.__esModule?function(){return t.default}:function(){return t};return r.d(n,"a",n),n},r.o=function(t,n){return Object.prototype.hasOwnProperty.call(t,n)},r.p="",r(r.s=0)}([function(t,n,r){t.exports=r(1)},function(t,n,r){"use strict";r.r(n);var e=function(t){return"function"==typeof t},o=function(t){if(e(t))return t},i=function(t,n){return function(t){return"number"==typeof t}(t)?0===t?1/0:t:n};function a(){if(this.tasks.list.length)this.tasks.running<this.concurrency&&(this.tasks.list.shift()(function(){this.tasks.completed++,this.tasks.running--,this.duration.total=Date.now()-this.duration.start,e(this.onDone)&&this.onDone(this.tasks);a.call(this)}.bind(this)),this.tasks.running++);else if(this.tasks.completed===this.tasks.total&&(this.duration.end=Date.now(),this.duration.total=this.duration.end-this.duration.start,this.__working=!1,e(this.onEnd))){var t=this.tasks.completed,n=this.duration;this.onEnd({completed:t,duration:n})}}function s(){if(!this.__working&&(this.duration.start=Date.now(),this.__working=!0,e(this.onStart))){var t=this.duration;this.onStart({duration:t})}}function u(){s.call(this),a.call(this)}var c={already_running:"Cannot start TaskRunner instance as it is already running!",auto_start_true:"Cannot programmatically start TaskRunner instance as autoStart is true!",add_requires_function:'The "add" operation requires a function. Check if the first argument is a function!',add_multiple_requires_array_of_functions:'The "addMultiple" operation requires an array of functions. Check if the first argument is an array and whether all the items in the array are functions!'},l=function(t){return"[TaskRunner]"+this.config.name+": "+c[t]};r.d(n,"default",function(){return y});var f,h,d,p=Object.assign||function(t){for(var n=1;n<arguments.length;n++){var r=arguments[n];for(var e in r)Object.prototype.hasOwnProperty.call(r,e)&&(t[e]=r[e])}return t};var y=(h=f=function t(){var n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};!function(t,n){if(!(t instanceof n))throw new TypeError("Cannot call a class as a function")}(this,t),d.call(this);var r=n.concurrency,e=n.onStart,a=n.onDone,s=n.onEnd,u=function(t,n){var r={};for(var e in t)n.indexOf(e)>=0||Object.prototype.hasOwnProperty.call(t,e)&&(r[e]=t[e]);return r}(n,["concurrency","onStart","onDone","onEnd"]);this.config=p({autoStart:!0,name:"Runner "+t.runnerCount++},u),this.concurrency=i(r,3),this.onStart=o(e),this.onDone=o(a),this.onEnd=o(s)},f.runnerCount=0,d=function(){var t=this;this.__working=!1,this.tasks={list:[],total:0,completed:0,running:0},this.duration={start:0,end:0,total:0},this.setConcurrency=function(n){t.concurrency=i(n,3)},this.start=function(){if(t.__working)return console.warn(l.call(t,"already_running")),!1;if(t.config.autoStart)return console.warn(l.call(t,"auto_start_true")),!1;s.call(t);for(var n=0;n<t.concurrency;n++)a.call(t);return!0},this.add=function(n){if(e(n)){var r=t.config.autoStart;return t.tasks.list.push(n),t.tasks.total++,r&&u.call(t),!0}throw new TypeError(l("add_requires_function"))},this.addMultiple=function(n){if(function(t){return t.constructor===Array}(n)&&n.every(function(t){return e(t)})){var r=t.config.autoStart;return t.tasks=p({},t.tasks,{list:[].concat(t.tasks.list,n),total:t.tasks.list.length+n.length}),r&&u.call(t),!0}throw new TypeError(l.call(t,"add_multiple_requires_array_of_functions"))},this.remove=function(n){t.tasks.list.splice(n,1),t.tasks.total=t.tasks.list.length},this.removeAll=function(){t.tasks.list=[],t.tasks.total=0}},h)}]).default}); | ||
!function(t,n){"object"==typeof exports&&"object"==typeof module?module.exports=n():"function"==typeof define&&define.amd?define([],n):"object"==typeof exports?exports.TaskRunner=n():t.TaskRunner=n()}(window,function(){return function(t){var n={};function r(e){if(n[e])return n[e].exports;var o=n[e]={i:e,l:!1,exports:{}};return t[e].call(o.exports,o,o.exports,r),o.l=!0,o.exports}return r.m=t,r.c=n,r.d=function(t,n,e){r.o(t,n)||Object.defineProperty(t,n,{enumerable:!0,get:e})},r.r=function(t){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(t,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(t,"__esModule",{value:!0})},r.t=function(t,n){if(1&n&&(t=r(t)),8&n)return t;if(4&n&&"object"==typeof t&&t&&t.__esModule)return t;var e=Object.create(null);if(r.r(e),Object.defineProperty(e,"default",{enumerable:!0,value:t}),2&n&&"string"!=typeof t)for(var o in t)r.d(e,o,function(n){return t[n]}.bind(null,o));return e},r.n=function(t){var n=t&&t.__esModule?function(){return t.default}:function(){return t};return r.d(n,"a",n),n},r.o=function(t,n){return Object.prototype.hasOwnProperty.call(t,n)},r.p="",r(r.s=0)}([function(t,n,r){t.exports=r(1)},function(t,n,r){"use strict";r.r(n);var e=function(t){return"function"==typeof t},o=function(t){if(e(t))return t},i=function(t,n){return function(t){return"number"==typeof t}(t)?0===t?1/0:t:n};function a(){if(this.tasks.list.length)this.tasks.running<this.concurrency&&(this.tasks.list.shift()(function(){this.tasks.completed++,this.tasks.running--,this.duration.total=Date.now()-this.duration.start,e(this.onDone)&&this.onDone(this.tasks);a.call(this)}.bind(this)),this.tasks.running++);else if(this.tasks.completed===this.tasks.total&&(this.duration.end=Date.now(),this.duration.total=this.duration.end-this.duration.start,this.__working=!1,e(this.onEnd))){var t=this.tasks.completed,n=this.duration;this.onEnd({completed:t,duration:n})}}function s(){if(!this.__working&&(this.duration.start=Date.now(),this.__working=!0,e(this.onStart))){var t=this.duration;this.onStart({duration:t})}}function u(){s.call(this),a.call(this)}function c(){if(this.tasks.running<this.concurrency)for(var t=this.tasks.running;t<this.concurrency;t++)a.call(this)}var l={already_running:"Cannot start TaskRunner instance as it is already running!",auto_start_true:"Cannot programmatically start TaskRunner instance as autoStart is true!",add_requires_function:'The "add" operation requires a function. Check if the first argument is a function!',add_multiple_requires_array_of_functions:'The "addMultiple" operation requires an array of functions. Check if the first argument is an array and whether all the items in the array are functions!'},f=function(t){return"[TaskRunner]"+this.config.name+": "+l[t]};r.d(n,"default",function(){return _});var h,d,p,y=Object.assign||function(t){for(var n=1;n<arguments.length;n++){var r=arguments[n];for(var e in r)Object.prototype.hasOwnProperty.call(r,e)&&(t[e]=r[e])}return t};var _=(d=h=function t(){var n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:{};!function(t,n){if(!(t instanceof n))throw new TypeError("Cannot call a class as a function")}(this,t),p.call(this);var r=n.concurrency,e=n.onStart,a=n.onDone,s=n.onEnd,u=function(t,n){var r={};for(var e in t)n.indexOf(e)>=0||Object.prototype.hasOwnProperty.call(t,e)&&(r[e]=t[e]);return r}(n,["concurrency","onStart","onDone","onEnd"]);this.config=y({autoStart:!0,name:"Runner "+t.runnerCount++},u),this.concurrency=i(r,3),this.onStart=o(e),this.onDone=o(a),this.onEnd=o(s)},h.runnerCount=0,p=function(){var t=this;this.__working=!1,this.tasks={list:[],total:0,completed:0,running:0},this.duration={start:0,end:0,total:0},this.setConcurrency=function(n){t.concurrency=i(n,3),t.__working&&c.call(t)},this.start=function(){return t.__working?(console.warn(f.call(t,"already_running")),!1):t.config.autoStart?(console.warn(f.call(t,"auto_start_true")),!1):(s.call(t),c.call(t),!0)},this.add=function(n){if(e(n)){var r=t.config.autoStart;return t.tasks.list.push(n),t.tasks.total++,r&&u.call(t),!0}throw new TypeError(f("add_requires_function"))},this.addMultiple=function(n){if(function(t){return t.constructor===Array}(n)&&n.every(function(t){return e(t)})){var r=t.config.autoStart;return t.tasks=y({},t.tasks,{list:[].concat(t.tasks.list,n),total:t.tasks.total+n.length}),r&&u.call(t),!0}throw new TypeError(f.call(t,"add_multiple_requires_array_of_functions"))},this.remove=function(n){t.tasks.list.splice(n,1),t.tasks.total=t.tasks.list.length},this.removeAll=function(){t.tasks.list=[],t.tasks.total=0}},d)}]).default}); | ||
//# sourceMappingURL=concurrent-tasks.min.js.map |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
45444
692