tasks-manager
Advanced tools
Comparing version 0.2.3 to 0.2.4
@@ -9,12 +9,11 @@ const { Task } = require('../../src'); | ||
}, | ||
interval: 500, | ||
interval: 10000, | ||
async balancers() { | ||
const balancers = await new Promise((resolve) => { | ||
setTimeout(() => { | ||
resolve(['Value A', 'Value B']); | ||
}); | ||
}, 300); | ||
return balancers; | ||
const balacing = new Set(); | ||
for (let i = 0; i < 15; i += 1) { | ||
balacing.add(i); | ||
} | ||
return [...balacing]; | ||
}, | ||
}); |
{ | ||
"name": "tasks-manager", | ||
"version": "0.2.3", | ||
"version": "0.2.4", | ||
"description": "Simple and useful tasks manager for nodejs.", | ||
@@ -5,0 +5,0 @@ "main": "src/index.js", |
@@ -22,4 +22,3 @@ /* eslint-disable global-require */ | ||
} | ||
balancers.forEach((balancer) => { | ||
const tasks = balancers.map((balancer) => { | ||
const taskBalancer = spawn('node', [ | ||
@@ -39,6 +38,2 @@ Path.join(__dirname, 'manager.js'), | ||
process.on('SIGINT', () => { | ||
taskBalancer.kill('SIGINT'); | ||
}); | ||
taskBalancer.on('close', (code) => { | ||
@@ -49,3 +44,10 @@ logger.warn( | ||
}); | ||
return taskBalancer; | ||
}); | ||
process.on('SIGINT', () => { | ||
tasks.forEach((taskToKill) => { | ||
taskToKill.kill('SIGINT'); | ||
}); | ||
}); | ||
} | ||
@@ -52,0 +54,0 @@ |
8541
195