es6 Promise 串行执行

Llwcbest发布于8 年前最后回复8 年前|8 回复5707 浏览0 收藏

并行执行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;
        });
 };

查看回复

atian25#1·8 年前

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

cnwhy#2·8 年前

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

waitingsong#3·8 年前

简单的异步流控制用原生的或者第三方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$
 }