在开发过程中不同的语言都有遇到 callback hell(回调地狱), 回调一般出现在异步操作中。
简单的例子:
① 从网络获取图片
② 将图片进行压缩
③ 压缩后的数据保存到本地
以上几个操作都属于异步操作,
op1(callback(){
success(){
op2(callback(){
success(){
op3(callback(){
success(){
// done
}
error(e){
}
})
}
error(e){
}
})
}
error(e){
}
})
不同语言设计针对此都有对应的解决方案,将回调写成流水线,将复杂的操作变成一条线。
Rxjava
:java 中处理异步
Promise
: JavaScript 中处理异步
写起来类似于下面的代码:
op1()
.then(op2)
.then(op3)
.catch(e)
.done();
Promise
对象代表一个异步操作,有三种状态: Pending
(进行中)、 Resolved
(已完成,又称Fulfilled)和 Rejected
(已失败)。
rxjava
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
// ... some code
if (/* 异步操作成功 */){
subscriber.onNext(value);
subscriber.onCompleted();
} else {
subscriber.onError(error);
}
});
Promise
var promise = new Promise(function(resolve, reject) {
// ... some code
if (/* 异步操作成功 */){
resolve(value);
} else {
reject(error);
}
});
rxjava
observable.doOnNext()
.map
.filter
.doOnNext()
.subscribe(
public void onCompleted() {
// ....
}
public void onError(Throwable e) {
// ...
}
public void onNext(AppInfo appInfo) {
// ...
}
);
promise
promise.then(function(){
}).then(function(){
}).catch(function(error){
});
类似于 Observable ob = Observable.merge(ob1,ob2,ob3)
Promise.all方法用于将多个Promise实例,包装成一个新的Promise实例。
var p = Promise.all([p1, p2, p3]);
上面代码中, Promise.all
方法接受一个数组作为参数, p1、p2、p3
都是Promise对象的实例。(Promise.all方法的参数可以不是数组,但必须具有Iterator接口,且返回的每个成员都是Promise实例。)
p的状态由p1、p2、p3决定,分成两种情况。
(1)只有 p1、p2、p3
的状态都变成fulfilled,p的状态才会变成fulfilled,此时p1、p2、p3的返回值组成一个数组,传递给p的回调函数。
(2)只要 p1、p2、p3
之中有一个被rejected, p的状态就变成rejected
,此时第一个被reject的实例的返回值,会传递给p的回调函数。
var p = Promise.race([p1,p2,p3]);
Promise.race
方法同样是将多个Promise实例,包装成一个新的Promise实例。
上面代码中,只要 p1、p2、p3
之中有一个实例率先改变状态, p的状态就跟着改变
。那个率先改变的Promise实例的返回值,就传递给p的回调函数。
不管 Promise
对象最后状态如何,都会执行的操作 。
http://es6.ruanyifeng.com/?search=fetch&x=0&y=0#docs/promise
https://mcxiaoke.gitbooks.io/rxdocs/content/operators/Merge.html
文章来自:http://hanks.xyz