javascript 支持链式调用的异步调用框架Async.Operation
作者:bea
代码如下: Async = {}; Async.Operation = function(options) { options = options || {}; var callbackQueue = []; var chain = (options.chain && options.chain === true) ? true : false; var started = false; var innerChain = null; thi
代码如下:
Async = {};
Async.Operation = function(options) {
options = options || {};
var callbackQueue = [];
var chain = (options.chain && options.chain === true) ? true : false;
var started = false;
var innerChain = null;
this.result = undefined;
this.state = "running";
this.completed = false;
this.yield = function(result) {
var self = this;
if (!chain) {
self.result = result;
self.state = "completed";
self.completed = true;
} else {
started = true;
self.result = result;
self.state = "chain running";
self.completed = false;
}
setTimeout(function() {
if (!innerChain) {
while (callbackQueue.length > 0) {
var callback = callbackQueue.shift();
if (chain) {
callbackResult = callback(self.result);
self.result = callbackResult;
if (callbackResult && callbackResult instanceof Async.Operation) {
innerChain = Async.chain();
while (callbackQueue.length > 0) {
innerChain.next(callbackQueue.shift());
}
innerChain.next(function(result) {
self.result = result;
self.state = "completed";
self.completed = true;
return result;
});
callbackResult.addCallback(function(result) {
self.result = result;
innerChain.go(result);
});
}
} else {
callback(self.result);
}
}
if (!innerChain) {
self.state = "completed";
self.completed = true;
}
} else {
while (callbackQueue.length > 0) {
innerChain.next(callbackQueue.shift());
}
innerChain.next(function(result) {
self.result = result;
self.state = "completed";
self.completed = true;
return result;
});
}
}, 1);
return this;
};
this.go = function(initialArgument) {
return this.yield(initialArgument);
}
this.addCallback = function(callback) {
callbackQueue.push(callback);
if (this.completed || (chain && started)) {
this.yield(this.result);
}
return this;
};
this.next = function(nextFunction) {
return this.addCallback(nextFunction);
};
};
Async.chain = function(firstFunction) {
var chain = new Async.Operation({ chain: true });
if (firstFunction) {
chain.next(firstFunction);
}
return chain;
};
Async.go = function(initialArgument) {
return Async.chain().go(initialArgument);
}
有用 | 无用
猜你喜欢
您可能感兴趣的文章:
- javascript 局部页面打印实现代码
- jQuery 解析xml文件
- ext 代码生成器
- JavaScript 变量作用域及闭包
- JavaScript 的方法重载效果
- JQuery 小练习(实例代码)
- js正确获取元素样式详解
- JavaScript 乱码问题
- jquery ui dialog里调用datepicker的问题
- jquery select(列表)的操作(取值/赋值)
- asp(javascript)全角半角转换代码 dbc2sbc
- javascript Array.remove() 数组删除
- 实现连缀调用的map方法(prototype)
- Extjs ajax同步请求时post方式参数发送方式
- 同一个表单 根据要求递交到不同页面的实现方法小结
- javascript dragable的Move对象
- 让 JavaScript 轻松支持函数重载 (Part 2 - 实现)
- 让JavaScript 轻松支持函数重载 (Part 1 - 设计)
- JavaScript 异步调用框架 (Part 6 - 实例 & 模式)