基于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 –