ステップパターンと非同期呼び出しのネストの類似

MongoDBでデータを操作するためのモデルを実装するとき、非同期呼び出しのネストに関する問題を何らかの形で回避する必要があるという結論に達しました。 Node.jsのStepの存在を知らなかったため、自分の自転車を作成することにしました。 親愛なるHabroユーザーの皆さんと共有したいと思います。

エントリー

呼び出しの問題と、キュー内の次の呼び出しへの情報のさらなる転送を解決するために、AQueueモジュール（非同期呼び出しの順次キューの実装）が生まれました。 このモジュールの実装には、Express.jsの中間ルーティングレイヤーの実装で使用される原則があります（たとえば、特定のビューへのアクセスの可能性をチェックするため）。 このメカニズムは、必要なパラメーターを渡してnext（）というコールバック関数を呼び出すことで実装されます。



それでは始めましょう！

実装

キューを編成するために、関数が呼び出される順序で入力される配列が選択されました。

• AddTo関数-次の関数をキューに追加します。
• 関数next- 次の関数を順番に呼び出すことができます。
• 完了した関数-正常に完了した場合、またはerrパラメーターがnullでない場合に呼び出されます
• 関数の実行 -キューの順に呼び出しメカニズムを起動します。
• qプロパティ-関数を配列に格納するために使用されます。
• Cbプロパティ-呼び出しキュー完了関数を格納するために使用されます。

1. 関数 AQueue （ ） {
2. var that = this ;
3. あれ。 q = [ ] ;
4. あれ。 cb = null ;
6. あれ。 addTo = function （ f ） {
7. あれ。 q プッシュ （ f ） ;
8. それを返す ;
9. } ;
11. あれ。 next = function （ err 、 data ） {
12. if （ that。q。length > 0 ） {
13. var f =それ。 q シフト （ ） ;
14. if （ err ） {
15. あれ。 q = [ ] ;
16. あれ。 cb （エラー、データ） ;
17. } else {
18. f （つまり、 次 、エラー、データ） ;
19. }
20. } else {
21. あれ。 cb （エラー、データ） ;
22. }
23. } ;
25. あれ。 完了 = 関数 （ cb ） {
26. あれ。 cb = cb ;
27. それを返す ;
28. } ;
30. あれ。 run = function （ ） {
31. それを返します。 next （ null 、 null ） ;
32. } ;
33. }
35. 輸出。 AQueue = AQueue ;

使用する

以下は、AQueueモジュールの使用例です。

1. var AQueue = reqiure （ 'aqueue' ） 。 AQueue
3. var aq = new AQueue （ ） ;
4. 水溶液 addTo （ function （ next 、 err 、 data ） {
5. //必要なアクションを実行します
6. 次（エラー、データ） ;
7. } ） 。 addTo （ function （ next 、 err 、 data ） {
8. //追加のアクションを実行します
9. //オブジェクトをラップすることでデータを結合できます
10. next （ err 、 { data ： data 、 checked ： true } ） ;
11. } ） 。 完了 （ function （ err 、 data ） {
12. //最終アクションを実行します。
13. } ） 。 実行 （ ） ;