Nuxt CNode：Node.js专业中文社区

es6 Promise 串行执行

发布于 7 年前作者 lwcbest 5440 次预览最后一次回复是 7 年前来自分享

并行执行Promise.all() 那么串行怎么写？直接上代码:

const  promisesFuncs = [promise1,promise2,...];
const computeSinglePromise = function (promisesFuncs, initParams) {
    let resultsArray = [];
    return promiseFuncs.reduce((promise, fn, index) => {
         console.log("reduce start", index);
         return promise.then((result) => {
             resultsArray.push(result);
             return fn(result);
         });
     }, Promise.resolve(initParams))
         .then(() => {
            return resultsArray;
        });
 };

8 回复

atian25

1楼•7 年前

https://github.com/sindresorhus/promise-fun 你值得拥有

cnwhy

2楼•7 年前

原生的.then就是串行的; 如果你的串行没有依赖关系,用bluebird吧 Promise.map 方法可以配置并发数; 也还可以试试我写的一个基于Promise的队列 promise-queue-plus

waitingsong

3楼•7 年前

简单的异步流控制用原生的或者第三方promise插件，复杂的就上异步流大杀器 rxjs

大致思路供参考

const combinePromiseObb = function (promisesFuncs, initParams) {
	const { defer, from } = rxjs
	const { scan } = rxjs.operators

	const ret$ = from(promisesFuncs).pipe(
		scan((acc, curr) => {
			return defer(() => curr(acc))
		}, initParams),
	)
	return ret$
 }

rxjs 的逻辑清晰多了

可对结果数据处理

const combinePromiseObb = function (promisesFuncs, initParams) {
	const { defer, from } = rxjs
	const { map, scan } = rxjs.operators

	const ret$ = from(promisesFuncs).pipe(
		scan((acc, curr) => {
			return defer(() => curr(acc))
				// 可以在这儿对结果数据进行转换、变形、过滤
				.pipe(
					map(res => res + 1),
				)
			
		}, initParams),
	)
	return ret$
 }