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

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?

扫码关注w3ctech微信公众号