0

いくつかのオブザーバブルを連鎖させ、実行されたオブザーバブルに応じて何らかのアクションを実行しようとしています。しかし、私は奇妙な行動に直面しました。

class MainActivity : AppCompatActivity() {

    val TAG: String = MainActivity::class.java.name

    private lateinit var clicker: TextView

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)
        clicker = findViewById(R.id.clicker) as TextView
        clicker.setOnClickListener {
            val i = AtomicInteger()

            getFirstObservable()
                .subscribeOn(Schedulers.computation())
                .observeOn(AndroidSchedulers.mainThread())
                .doOnNext {
                    showMessage(i, it)
                }
                .flatMap { getSecondObservable() }
                .doOnNext {
                    showMessage(i, it)
                }
                .flatMap { getThirdObservable() }
                .doOnNext {
                    showMessage(i, it)
                }
                .subscribe()
        }
    }

    fun getFirstObservable(): Observable<String> {
        return Observable.fromCallable {
            Thread.sleep(2000)
            "Hello"
        }
    }

    fun getSecondObservable(): Observable<Int> {
        return Observable.fromCallable {
            Thread.sleep(2000)
            3
        }
    }

    fun getThirdObservable(): Observable<String> {
        return Observable.fromCallable {
            Thread.sleep(2000)
            "World!"
        }
    }

    fun showMessage(i: AtomicInteger, obj: Any) {
        val msg = "Message #${i.incrementAndGet()}: from ${Thread.currentThread().name}: $obj"
        Log.e(TAG, msg)
        clicker.text = msg
        Toast.makeText(this, msg, Toast.LENGTH_SHORT).show()
    }
}

この例では、ログは 2 秒ごとに表示されますが、ビューに関するすべての変更は、最後の監視対象が終了するときに行われます。

12-04 01:11:30.465 19207-19207/com.googlevsky.rxtest E/com.googlevsky.rxtest.MainActivity: Message #1: from main: Hello
12-04 01:11:32.473 19207-19207/com.googlevsky.rxtest E/com.googlevsky.rxtest.MainActivity: Message #2: from main: 3
12-04 01:11:34.479 19207-19207/com.googlevsky.rxtest E/com.googlevsky.rxtest.MainActivity: Message #3: from main: World!

AndroidScheduler.mainThread() の動作だと思います。この行を削除して、このようなビューで変更をラップすると

Handler(Looper.getMainLooper()).post {
    clicker.text = msg
    Toast.makeText(this, msg, Toast.LENGTH_SHORT).show()
}

行動が正しくなります。誰かがこの動作を説明し、この問題を解決する正しい方法を提案できますか?

4

1 に答える 1

2

ほとんどのコードは、スリープを含め、メイン スレッドで実行されています。オブザーバブルが作成されると、特に指定されていない限り、現在のスレッドでサブスクライブされ、監視されます。2 番目と 3 番目のオブザーバブルを作成すると、それらはメイン スレッド上にあります。さらに、監視可能な作業のバックグラウンド処理がないため、サブスクライブすると現在のスレッドですぐに実行されます。したがって、すべての作業と監視はメイン スレッドで行われ、Android OS に戻ることはありません。UI は、メイン スレッドで時間を待機してブロックされます。これらのスリープ時間を増やすと、ANR を強制できます。これを修正するには、オブザーバブルごとにobserveOnとを指定して、作業をそれぞれの計算スレッドにプッシュすることができます。subscribeOn

getFirstObservable().subscribeOn(Schedulers.computation())
                    .observeOn(AndroidSchedulers.mainThread())
                    .doOnNext {
                        showMessage(i, it)
                    }
                    .flatMap {
                        getSecondObservable().subscribeOn(Schedulers.computation())
                                             .observeOn(AndroidSchedulers.mainThread()) 
                    }
                    .doOnNext {
                        showMessage(i, it)
                    }
                    .flatMap { 
                        getThirdObservable().subscribeOn(Schedulers.computation())
                                            .observeOn(AndroidSchedulers.mainThread()) 
                    }
                    .doOnNext {
                        showMessage(i, it)
                    }
                    .doOnNext {
                        showMessage(i, it)
                    }
                    .subscribe()
于 2016-12-04T03:57:08.327 に答える