作者热门文章
- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我创建了带有无限进度条的简单 Activity ,我尝试使用 RxJava 运行耗时的方法来防止 UI 线程阻塞,但每次 UI 线程都被阻塞。我认为我的解决方案在发射 Observable 方面存在问题。谁能帮我?我是 RX 的初学者。
public class MainActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
}
public void doSomething(View view) {
doHeavyStuff()
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.doOnNext(new Action1() {
@Override
public void call(Object o) {
Toast.makeText(getApplicationContext(), "FINISHED", Toast.LENGTH_SHORT).show();
}
})
.subscribe();
}
private Observable doHeavyStuff() {
for (int i = 0; i < 999999999; i++) {
for (int j = 0; j < 2; j++) {
}
}
return Observable.just(1);
}
最佳答案
对于 RxJava2,一个可能的解决方案是:
Single.fromCallable(() -> loadInBackground())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe((resultObject) -> { updateUi(resultObject) });
Single.fromCallable(new Callable<Object>() {
@Override
public Object call() throws Exception {
return loadInBackground();
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Object>() {
@Override
public void accept(Object resultObject) throws Exception {
updateUi(resultObject);
}
});
private Object loadInBackground() {
// some heavy load code
return resultObject;
}
private void updateUi(Object resultObject) {
// update your Views here
}
关于AndroidRX - 在后台运行方法,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31498847/
我创建了带有无限进度条的简单 Activity ,我尝试使用 RxJava 运行耗时的方法来防止 UI 线程阻塞,但每次 UI 线程都被阻塞。我认为我的解决方案在发射 Observable 方面存在问
我是一名优秀的程序员,十分优秀!