async之waterfall模式

巩阳秋
2023-12-01

waterfall按照async.waterfall中的顺序进行执行, 且前一个函数产生的值,都将传给下一个函数。

console.log("===========waterfall===========");
var async = require('async');
    var task1 =function(callback){
		console.log("task1");
		callback(null,"task1")
	}
	var task2 =function(temp,callback){
		console.log("task2");
		console.log("task1函数传入的值: "+temp);
		callback(null,"task2")
	}
	var task3 =function(temp,callback){
		console.log("here is task3");
		console.log("from  task2: "+temp);
		callback(null,"task3")
	}
	console.time("waterfall方法");
	async.waterfall([task1,task2,task3],function(err,result){
		console.log("waterfall");
		if (err) {
			console.log(err);
		}
		console.log("result : "+result);
		console.timeEnd("waterfall方法");
	})

 

需要注意的是 waterfall 的 tasks 参数只能是数组类型。 当中途有函数出错,其err直接传给最终callback,结果被丢弃,后面的函数不再执行。

 

 类似资料: