可能这个用得最多的还是在采集上, 不过想着还是做成一个一般化的封装, 这样未来有需要的时候可以方便地用上.

github https://github.com/vilic/promise-pool

npm install promise-pool

例子 (TypeScript)
更新了下, 去掉了 processor return false 表示失败这个设定. 另外封装了一下 Q 的 retry, 见
https://github.com/vilic/q-retry.

import Q = require('q');
import promisePool = require('promise-pool');
var pool = new promisePool.Pool<number>((taskDataId, index) => {
 if (Math.random() < 0.1) {
 throw new Error('err 1');
 }
 return Q.delay(Math.floor(Math.random() * 5000)).then(function () {
 if (Math.random() < 0.1) {
 throw new Error('err 2');
 }
 if (index == 40) {
 console.log('pausing...');
 pool.pause().then(function () {
 console.log('paused.');
 }).delay(5000).then(function () {
 console.log('resuming...');
 pool.resume();
 });
 }
 });
}, 20);
pool.retries = 5;
for (var i = 0; i < 100; i++) {
 pool.add(i);
}
pool.start(progress => {
 if (progress.success) {
 console.log(progress.fulfilled + '/' + progress.total);
 }
 else {
 console.log(
 'task ' + progress.index + ' failed with ' +
 (progress.error ? progress.error.message : 'no error') + ', ' +
 progress.retries + ' retries left.'
 );
 }
}).then(result => {
 console.log('completed ' + result.total + ' tasks.');
});

另外现在开始用 TypeScript 写自己的项目, 感觉还不错, 常用的库都能找到 NuGet 管理的 .d.ts 文件. 不知道大家怎么看 TypeScript?