基於http://i.stack.imgur.com/9DDQP.png您需要的是一個很好的流程庫,它允許您在節點中管道同步和異步調用。
一個這樣的庫是https://github.com/isaacs/slide-flow-control(在那裏也請看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 –