我使用infinity progres bar创建了简单的活动,并且我试图使用Rx
Java运行耗时的方法来阻止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);
}
@H_301_4@
解决方法
你的doHeavyStuff()在调用线程上执行计算,你只需将结果包装到Observable中.
为了将计算包装成可观察的,你应该使用延迟
为了将计算包装成可观察的,你应该使用延迟
Observable.defer(new Func0<Observable<Integer>>() {
@Override
public Observable<Integer> call() {
return Observable.just(doHeavyStuff());
}
});
然后你可以通过subscribeOn和observeOn方法指定线程
@H_301_4@ @H_301_4@ 原文链接：https://www.f2er.com/android/314314.html