Node.js 简易异步流程控制工具：AsyncManager

异步开发背景与问题

近期在 Node.js 开发中，初期因需求简单且部分 API 提供同步接口，常直接采用同步方式以节省时间。但随着项目深入，发现这种做法忽视了异步特性，且许多库并不提供同步 API，导致开发受阻。

转向异步开发后，代码结构逐渐变得复杂。

mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
//let's say fuck
                    });
                });
            });
        });
    });
});

AsyncManager 设计与实现

正如所见，这种层层嵌套的方式会导致代码极度混乱，如同“回调地狱”。为此，设计了一个小巧且实用的异步操作管理器，具体实现见下方代码。

局限性说明

待完善：目前版本未包含错误处理机制。

/*
* 异步管理器
* author : jser.me
 *
* 使用方法：
* var asyncMg = require('./AsyncManager');
* asyncMg
* .push(function( next ){
* some_aysnc_method().on('success'{
 *            ....
* next();
 *         })
 *     })
* .push(function( next ){
* other_aysnc_method().on('success'{
 *            ....
* next();
 *         })
 *     })
* .push( ... )
* .run() //执行
* .on('success', function(){
* allThings_is_down();
 *     });
 *
* push方法接受数组
 */
function typeOf( obj ){
 return Object.prototype.toString.call( obj ).match(/\[object ([^\]]*)\]/)[1];
}
function AsyncManager( arg ){
 this.execArrys = [];
 this.push( arg );
}
//使用系统带的继承方法
require('util').inherits( AsyncManager, require('events').EventEmitter );
//标记成功运行的函数数目
AsyncManager.prototype.succCount = 0;
//加入
AsyncManager.prototype.push = function( arg ) {
var This = this;
 if( typeOf(arg) == 'Array' ){
 arg.forEach( function(v,i){
 This.execArrys.push( v );
 });
 } else {
 This.execArrys.push( arg );
 }
return this; //链一个
};
//执行
AsyncManager.prototype.run = function(){
 var self = this;
if( this.succCount == this.execArrys.length ) {
 //所有函数成功执行后触发事件
 this.emit( 'success' );
 } else {
 this.execArrys[ this.succCount ]( self.run.bind( self ) );
 }
this.succCount++;
 return this; //链一个
};
exports = module.exports = function( arg ){
 return new AsyncManager( arg );
}