http://i.stack.imgur.com/9DDQP.pngに基づいて、ノードで同期と非同期の呼び出しをパイプラインで処理できる優れたフローライブラリが必要です。
このようなライブラリの1つはです(ここでもslide presoをご覧ください)。必要な作業のコードの概要は以下のとおりです。
これは自己文書化であり、わかりやすく、純粋なnodejs、uml、imgなどは必要ありません。
var chain = require("slide/chain")
, asyncMap = require("slide/async-map")
;
// start processing
main_loop(function() {
console.log("its done"); // when finished
});
function main_loop(cb) {
var res = [];
// each entry in chain below fires sequentially i.e. after
// the previous function completes
chain
([ [start_update_q, "user-foo"]
, [get_followed_users, chain.last]
, [get_favorites, chain.last]
, [calc_new_q]
, [push_results, chain.last]
]
, res
, cb
)
}
function get_favorites(users, cb) {
function fn(user, cb_) {
get_one_users_favorites(user, cb_);
}
// this will run thru get_favorites in parallel
// and after all user favorites are gotten it will fire
// callback cb
asyncMap(users, fn, cb);
}
// code in the various functions in chain here,
// remember to either return the callback on completion.
// or pass it as an arg to the async call you make within the
// function as above i.e. asyncMap will fire cb on completion
これはまさに私が探していたものです。私はSeqで遊び始めましたが、Node/npmのインストールを壊しました:http://goo.gl/fhilo –