harish2704/node-job-manager
1
0
Fork 0
mirror of https://github.com/harish2704/node-job-manager.git synced 2026-09-10 13:11:08 +00:00
Code Issues Projects Releases Wiki Activity

Fix: setConcurrency

Browse Source
This commit is contained in:
harish2704
2014-09-01 15:28:15 +05:30
parent 3a3043221b
commit ea2de93dbd
1 changed files with 11 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/JobManager.js
+11 -1
View File
@@ -48,6 +48,7 @@ JobManager.prototype.setConcurrency = function( newVal ){
} }
this.tmpPoolLen += additionalPoolBlocks * this.workers.length ; this.tmpPoolLen += additionalPoolBlocks * this.workers.length ;
} }
this.concurrency = newVal;
}; };
/* /*
@@ -70,8 +71,11 @@ JobManager.prototype.getFromPool = function(){
JobManager.prototype.$doWork_ = function( cb ){ JobManager.prototype.$doWork_ = function( cb ){
var self = this; var self = this;
var worker = self.getFromPool();
var task = self.tasks.splice(0, 1)[0]; var task = self.tasks.splice(0, 1)[0];
if( task == undefined ){
if( this.onStopped ){ this.onStopped(); }
}
var worker = self.getFromPool();
this.work( task, worker, function(err){ this.work( task, worker, function(err){
if(err){ if(err){
self.onError(err, task, worker ); self.onError(err, task, worker );
@@ -114,6 +118,12 @@ JobManager.prototype.pause = function(){
this.state = STATE.NOT_RUNNING; this.state = STATE.NOT_RUNNING;
}; };
JobManager.prototype.stop = function(){
this.state = STATE.NOT_RUNNING;
if( this.onStopped ){ this.onStopped(); }
};
JobManager.prototype.resume = function(){ JobManager.prototype.resume = function(){
this.start(); this.start();
}; };