This commit is contained in:
Horiuchi_H
2014-12-26 16:25:50 +09:00
parent 350a6abd9e
commit 195d5105cc
2 changed files with 83 additions and 12 deletions
+49
View File
@@ -117,6 +117,55 @@ asyncblock(function(flow) {
})();
// Parallel task rate limiting
(function() {
asyncblock(function(flow) {
flow.queue(function(callback: Function) {
setTimeout(callback, 1000);
});
flow.wait(); //This will wait for about a second
});
asyncblock(function(flow) {
flow.maxParallel = 2;
process.nextTick(function(){
flow.queue(function(callback: Function) {
setTimeout(callback, 1000);
});
flow.queue(function(callback: Function) {
setTimeout(callback, 2000);
});
flow.queue(function(callback: Function) {
setTimeout(callback, 3000);
});
flow.doneAdding();
});
flow.forceWait();
});
asyncblock(function(flow) {
setTimeout(flow.callback(), 1000);
flow.queue(function(callback: Function) {
setTimeout(callback, 1000);
});
flow.queue((callback: (err: any, res: string) => void) => {
callback(null, '');
});
flow.wait();
});
})();
// Task timeouts
(function() {