Parallel execution with max concurrency limit.
$ npm install gocsp-limit
var go = require('gocsp-go')
var limit = require('gocsp-limit')
var thunk = require('gocsp-thunk')
var readFile = thunk.ify(require('fs').readFile)
go(function* () {
var files = yield [
'example.js',
'index.js',
'package.json',
'README.md',
'test.js'
// parallel execution with max concurrency 3
].map(limit.wrap(3, function* (filename) {
return yield readFile(__dirname + '/' + filename, 'utf8')
}))
})
like go
in gocsp-go, but with max concurrency limit
Example:
var limitGo = limit(5)
for (var i = 0; i < 10; i++) {
limitGo(function* () {
// max 5 concurrency
// ...
})
}
like go.wrap
in gocsp-go, but with max concurrency limit
Example:
go(function* () {
var files = yield [
'example.js',
'index.js',
'package.json',
'README.md',
'test.js'
// parallel execution with max concurrency 3
].map(limit.wrap(3, function* (filename) {
return yield readFile(__dirname + '/' + filename, 'utf8')
}))
})
MIT