シンプルな Node.js 非同期操作マネージャー Sharing_JavaScript スキル

最近、nodejs について多くのことを書いてきましたが、やりたいことが比較的単純だったので、最初は非同期操作に遭遇しませんでした。そして、トラブルを避けるために API をチェックしたところ、同期操作があることがわかりました。 、私は同期機能を使用していましたが、これは問題ではありません。しかし、同期機能を使用する必要があるのは非常に恥ずかしいことであり、多くのものには同期 API がありません。

わかりました!非同期で書いていると、徐々にこのようなコードが出てきました。 。 。

コードをコピーします コードは次のとおりです:

mysql.query('xxxx')。 on(' 成功', function(){
mysql.query('xxxx').on('成功', function(){
mysql.query('xxxx').on('成功', function() {
mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
mysql.query('xxxx').on('success', function(){
});
});
});
});

まあ、このままだとコードがいかに醜いのかもおわかりでしょう。おばあさんの足布のように見えますので、次のような非同期操作マネージャーが生成されます。ふふ、これで十分です。コードについては、
などのコードを強調表示して説明しましょう。

TODO: 十分に包括的ではありません。たとえば、エラーが処理されません

コードをコピー コードは次のとおりです:

/*
* 非同期マネージャー
* 著者 : jser.me
*
* 使用法:
* var asyncMg = require('./AsyncManager') ;
* asyncMg
* .push(function(next){
* some_aysnc_method().on('success'{
* next();
*次へ( );
。 * })
* })
* .push( ... )
* .run() //
を実行 * .on('success', function() {
* allThings_is_down();
* });
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 );
});

これを返します。 // チェーン 1

};

//

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; // チェーン 1

};

exports = module.exports = function( arg ){
return new AsyncManager( arg );

}