订阅者的 onNext() 方法 运行 在哪个线程上?
Which thread does subscriber's onNext() method run on?
我有一个创建新 Observable 的用例:
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
final RequestFuture<String> futureRequest = RequestFuture.newFuture();
try{
//getResult() is a sync time consuming http connection
String response = getResult();
subscriber.onNext( response );
subscriber.onCompleted();
Log.e("call method","Thread is about to end" + Thread.currentThread().getId());
}
catch ( Exception e){
subscriber.onError( e );
}
}
}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
正如您所看到的,getResult() 方法是一个耗时的 http 调用,我正在以同步方式进行。我在 io 线程上订阅它并在 Android 的主线程上观察。
当我检索可观察对象并订阅它时:
subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
Log.e("on completed method", "Thread is ending "+ Thread.currentThread().getId());
}
@Override
public void onError(Throwable e) {
Toast.makeText( getContext(), "failed!",Toast.LENGTH_LONG ).show();
}
@Override
public void onNext(String s) {
Log.e("on Next method", "Thread is about to end" + Thread.currentThread().getId());
}
});
奇怪的是,我可以看到 call() 方法是 运行 在线程 id 为 372 上,订阅者的 onNext() 方法是线程 1 上的 运行 ,我认为它是来自 android.
的 UiThread
那么Rxjava实际上是如何处理这个线程变化的呢?它证明了调用方法中的订阅者不是我在 subscribe() 方法中使用的订阅者?
默认情况下,订阅者的 onNext 将 运行 在您调用 .subscribe
.
的同一线程上
但是在您的代码中有两个线程更改:
第一个是 subscribeOn(IO)
,它将 运行 .create
和 IO 链的其余部分。
之后你有 observeOn(mainThread)
它将把以下所有操作更改为 mainThread,包括 .subscribe()
.
中的最终方法
希望这能让您更好地理解这两个运算符的工作原理:https://medium.com/@diolor/observe-in-the-correct-thread-1939bb9bb9d2#.t6uagyarn
我有一个创建新 Observable 的用例:
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
final RequestFuture<String> futureRequest = RequestFuture.newFuture();
try{
//getResult() is a sync time consuming http connection
String response = getResult();
subscriber.onNext( response );
subscriber.onCompleted();
Log.e("call method","Thread is about to end" + Thread.currentThread().getId());
}
catch ( Exception e){
subscriber.onError( e );
}
}
}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread());
正如您所看到的,getResult() 方法是一个耗时的 http 调用,我正在以同步方式进行。我在 io 线程上订阅它并在 Android 的主线程上观察。
当我检索可观察对象并订阅它时:
subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
Log.e("on completed method", "Thread is ending "+ Thread.currentThread().getId());
}
@Override
public void onError(Throwable e) {
Toast.makeText( getContext(), "failed!",Toast.LENGTH_LONG ).show();
}
@Override
public void onNext(String s) {
Log.e("on Next method", "Thread is about to end" + Thread.currentThread().getId());
}
});
奇怪的是,我可以看到 call() 方法是 运行 在线程 id 为 372 上,订阅者的 onNext() 方法是线程 1 上的 运行 ,我认为它是来自 android.
的 UiThread那么Rxjava实际上是如何处理这个线程变化的呢?它证明了调用方法中的订阅者不是我在 subscribe() 方法中使用的订阅者?
默认情况下,订阅者的 onNext 将 运行 在您调用 .subscribe
.
但是在您的代码中有两个线程更改:
第一个是 subscribeOn(IO)
,它将 运行 .create
和 IO 链的其余部分。
之后你有 observeOn(mainThread)
它将把以下所有操作更改为 mainThread,包括 .subscribe()
.
希望这能让您更好地理解这两个运算符的工作原理:https://medium.com/@diolor/observe-in-the-correct-thread-1939bb9bb9d2#.t6uagyarn