AndroidRX – 在后台运行方法

概述我使用infinity progres bar创建了简单的活动,并且我试图使用Rx Java运行耗时的方法来阻止UI线程阻塞,但每次阻止UI线程.我认为我的解决方案在发射Observable方面存在问题.谁能帮我？我是RX的先生. public class MainActivity extends AppCompatActivity {@Overrideprotected void onCr 我使用infinity progres bar创建了简单的活动,并且我试图使用Rx Java运行耗时的方法来阻止UI线程阻塞,但每次阻止UI线程.我认为我的解决方案在发射Observable方面存在问题.谁能帮我？我是RX的先生.

public class MainActivity extends AppCompatActivity {@OverrIDeprotected 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);}

解决方法 你的doHeavyStuff()在调用线程上执行计算,你只需将结果包装到Observable中.
为了将计算包装成可观察的,你应该使用延迟

Observable.defer(new Func0<Observable<Integer>>() {    @OverrIDe    public Observable<Integer> call() {        return Observable.just(doHeavyStuff());    }});

然后你可以通过subscribeOn和observeOn方法指定线程

总结

以上是内存溢出为你收集整理的AndroidRX – 在后台运行方法全部内容，希望文章能够帮你解决AndroidRX – 在后台运行方法所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。