map
我是 Array.map() 函数的模拟，但用于异步任务。 我可以接受一个并发参数并返回一个 Promise，当所有任务完成后该 Promise 将被 resolved。 我的代码更短，特别是当用户需要限制并行任务的数量时非常有用。
看个具体的例子：
const bluebird = require('bluebird'); async function task(data, ms = 1000) { console.log(' in async task: ', data); await bluebird.delay(ms); return data; } bluebird.map(['A', 'B', 'C', 'D', 'E', 'F'], async (item) => { return task(item); }, { concurrency: 1 }).then((result) => { console.log('final result:', result); });
每隔一秒钟，打印一行语句：in async task: XX
map 输入参数全部被处理后，打印：final result：[ 'A', 'B', 'C', 'D', 'E', 'F' ]
如果把 Concurrency 参数改成 2，那么每秒钟同时处理两个元素。
each
BlueBird 采用一个可迭代的参数并像原生函数 Array.forEach() 一样对其进行循环。 它还采用了一个回调参数，它可以是异步函数，也可以是任何返回 Promise 的函数。 这个方法不会一次完成所有任务，而是一个接一个地完成任务。 换句话说，每个单位时间做一件事。 由于开发人员不能在原生的 Array.forEach() 函数内进行异步工作，这种场景下可以切换到 BlueBird 的 forEach 实现。
下面的代码和 concurrency = 1 的 map 效果完全一致：
const bluebird = require('bluebird'); async function task(data, ms = 1000) { console.log('in async task for each: ', data); await bluebird.delay(ms); return data; } bluebird.each(['A', 'B', 'C', 'D', 'E', 'F'], async (item) => { return task(item); }).then((result) => { console.log(result); });
some
some 将一组 promise 作为第一个参数，将 count 参数作为第二个参数。 该方法返回一个 Promise，一旦给定 Promise 数组中的 Promise 被 resolved 的个数达到了 count，some 返回的 Promise 就会被 resolve.
例如，如果您给我一个包含 10 个承诺和 3 个作为计数参数的列表，我将返回一个承诺，一旦您的列表中的 3 个承诺被履行，该承诺就会被履行。 结果，我返回一个数组，其中包含已履行承诺的结果。
看个具体的例子：
const bluebird = require('bluebird'); async function task(data, ms = 1000) { console.log(`${data} started`); await bluebird.delay(ms); console.log(`${data} done`); return data; } const promises = [2, 0, 1, 9].map(item => task(item ,item * 500)); bluebird.some(promises, 3).then((result) => { console.log(' bluebird 3 promised resolved: ', result); });
结果：0 1 2 被 resolve 之后，some 调用返回的 Promise 就 resolve 了：
