android - 为什么我的 RxJava 设置阻塞了我的 UI 线程？使用 BluetoothAdapter.startLeScan 回调

Question

我正在努力寻找阻塞我的 UI 线程的具体操作，我已经尝试了几个调度程序操作符，但我不确定如何让它工作。

我有一个带按钮的 UI，onClicked 正在启动蓝牙扫描并使用类似日志的字符串更新 textView(它显示了此刻正在发生的事情)。

这是我的 MainActivity:

 lateinit var disposable: Disposable
val textDataService = TextDataService()


override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    setContentView(R.layout.activity_scan_test)


    buttonScanTestStart.setOnClickListener {
        if (isBluetoothEnabled()) {
            textViewLog.text = ""

            buttonScanTestStop.visibility = View.VISIBLE
            buttonExportScanTestRaportSummary.visibility = View.GONE
            buttonExportScanTestRaportFull.visibility = View.GONE
            buttonScanTestStart.visibility = View.GONE

            disposable=
                    Scanner()
                            .discoverSingleDevice(this, "   ", textViewLog)
                            .doOnError {
                                setText("General error: ${it.message ?: it::class.java}", textViewLog)
                                setLogText("General error: ${it.message ?: it::class.java}")
                            }
                            .repeat(1)
                            .doOnComplete {
                                buttonScanTestStop.visibility = View.GONE
                            }
                            .doOnDispose {
                                log("TEST DISPOSED")
                            }
                            .subscribe()
        } else {
            Toast.makeText(this, "Please, enable bluetooth to start test.", Toast.LENGTH_SHORT).show()
        }
    }

    buttonScanTestStop.setOnClickListener {
        disposable.dispose()
        buttonScanTestStop.visibility = View.GONE
        buttonScanTestStart.visibility = View.VISIBLE
        buttonExportScanTestRaportSummary.visibility = View.VISIBLE
        buttonExportScanTestRaportFull.visibility = View.VISIBLE

        textDataService.generateScanGeneralStatisticsLogText(textViewLog)
    }

这是扫描仪类:

class Scanner {


private fun scan(context: Context, textView: TextView) = Observable.create<ScannedItem> { emitter ->
    val bluetoothAdapter = context.getBluetoothAdapter()
    if (bluetoothAdapter.isEnabled) {

        val scanCallback = BluetoothAdapter.LeScanCallback { bluetoothDevice, rssi, _ ->

            if(bluetoothDevice.name == null){
                    bluetoothRawLog("Scanned Item -> ${bluetoothDevice.logText()} | rssi = $rssi | time: = ${getCurrentTime()}")
                    scannedOtherDevices.add(bluetoothDevice.address)
            }
            else{
                if(!scannedDevices.contains(bluetoothDevice.name)){
                        setText("Scanned Item -> ${bluetoothDevice.logText()} | rssi = $rssi | time: = ${getCurrentTime()}\n", textView)

                    setLogText("Scanned Item -> ${bluetoothDevice.logText()} | rssi = $rssi | time: = ${getCurrentTime()}\n")
                }
                scannedDevices.add(bluetoothDevice.name)


            }
            bluetoothRawLog("Scanned Item -> ${bluetoothDevice.logText()} | rssi = $rssi")


            bluetoothDevice.name?.let {
                emitter.onNext(ScannedItem(it, bluetoothDevice.address))
            }
        }

        emitter.setCancellable { bluetoothAdapter.stopLeScan(scanCallback) }
        bluetoothAdapter.startLeScan(scanCallback)

    } else
        emitter.onError(IllegalStateException("Bluetooth turned off"))
}
        .doOnNext { log("Scanned -> $it") }
        .timeout(12, TimeUnit.SECONDS)
        .observeOn(AndroidSchedulers.mainThread())
        .doOnError { if (it is TimeoutException) setLogText("Scanner -> no named devices for 12 seconds: resetting...") }
        .retry { t -> t is TimeoutException }


  fun discoverSingleDevice(context: Context, searchName: String, textView: TextView): Observable<ScannedItem> = scan(context, textView)
        .filter { it.name.contains(searchName) }
        .take(1)

这是我用来设置文本的 Kotlin 扩展函数:

fun setLogText(text: String) {
    logBuffer.append(text)
}

fun setText(text: String, textView: TextView) {
    textView.append(text)
}

这也是我的布局:

<?xml version="1.0" encoding="utf-8"?>

<LinearLayout
    android:layout_margin="16dp"
    android:layout_width="wrap_content"
    android:layout_height="wrap_content"
    android:layout_gravity="center"
    android:orientation="horizontal">

    <Button
        android:layout_weight="1"
        android:id="@+id/buttonScanTestStart"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_gravity="center"
        android:text="Start Test" />
    <Button
        android:layout_weight="1"
        android:visibility="gone"
        android:id="@+id/buttonScanTestStop"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_gravity="center"
        android:text="Stop Test" />
    <Button
        android:layout_weight="1"
        android:id="@+id/buttonExportScanTestRaportFull"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_gravity="center"
        android:text="Export raport"
        android:visibility="gone" />

    <Button
        android:layout_weight="1"
        android:id="@+id/buttonExportScanTestRaportSummary"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:layout_gravity="center"
        android:text="Export summary"
        android:visibility="gone" />
</LinearLayout>

<LinearLayout
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:orientation="vertical">

    <LinearLayout
        android:visibility="gone"
        android:id="@+id/scanTestStartedLinearLayout"
        android:gravity="center"
        android:orientation="horizontal"
        android:layout_width="match_parent"
        android:layout_height="wrap_content">
        <TextView
            android:text="Test running..."
            android:layout_width="wrap_content"
            android:layout_height="wrap_content" />
        <ProgressBar
            android:id="@+id/scanTestProgressBar"
            android:layout_width="16dp"
            android:layout_height="16dp" />
    </LinearLayout>

    <TextView
        android:id="@+id/textViewScanTestLog"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:layout_margin="16dp"
        android:gravity="center" />

    <ScrollView
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:layout_margin="16dp"
        android:gravity="center">

        <LinearLayout
            android:layout_width="match_parent"
            android:layout_height="wrap_content"
            android:orientation="vertical">

            <TextView
                android:id="@+id/textViewLog"
                android:layout_width="match_parent"
                android:layout_height="wrap_content" />

        </LinearLayout>

    </ScrollView>

</LinearLayout>

所以文本很顺利地出现在我的 textView 中，一切正常。但是，当有更多可用设备可供扫描时，我无法通过单击按钮来停止测试。当我尝试单击它时，它只是卡住并且响应太晚了。

discoverSingleDevice 函数将永远运行，因为我过滤了来 self 的 editText(我用“”硬编码)的搜索名称以使其永远运行，我只想通过单击我的停止按钮来停止它布局。作为第二个参数，我从我的布局中将 textViewLog 传递给它(Kotlin 足够聪明，可以通过 id 找到它)

那么如何使用此设置防止阻塞 UI？

更新:

按照文超的建议，我做过这样的事情:

       val observable = Scanner()
                    .discoverSingleDevice(this, "   ", textViewLog)
                    .doOnError {
                        nexoSetText("General error: ${it.message ?: it::class.java}", textViewLog)
                        nexoSetLogText("General error: ${it.message ?: it::class.java}")
                    }
                    .repeat(1)
                    .doOnComplete {
                        buttonScanTestStop.visibility = View.GONE
                    }
                    .doOnDispose {
                        nexoLog("TEST DISPOSED")
                    }

         disposable =  observable
                    .subscribeOn(Schedulers.newThread()).subscribe()

然而，它并没有帮助，它不是那么简单。同样，我与其他运营商一起尝试了几件事。请具体说明我的情况 - 我提供了代码。

好像在扫描 2 分钟后，应用程序相当卡住。在日志中当然会出现 I/Choreographer:跳过 54 帧!应用程序可能在其主线程上做了太多工作。

更新 2:

正如 PhoenixWang 所建议的，我已经登录以检查 BluetoothAdapter 在哪个线程上运行。所以我在 Scanner 类的扫描方法中这样做了:

  private fun scan(context: Context, textView: TextView) = Observable.create<ScannedItem> { emitter ->
    val bluetoothAdapter = context.getBluetoothAdapter()
    if (bluetoothAdapter.isEnabled) {

        val scanCallback = BluetoothAdapter.LeScanCallback { bluetoothDevice, rssi, _ ->
            Log.v("BluetoothThread", "Running on: " + Thread.currentThread().name)
///the rest of the code

那么如何解决这个问题呢？我认为它实际上会在单独的线程(不是主线程)上运行，因为我已经完成了天真的修复，这在我的第一个更新中是可见的。你能帮忙吗？

更新 3:

所以问题出在 BluetoothAdapter.leScan - 它在主线程上运行，即使我做了这样的事情:

Observable.fromCallable{ bluetoothAdapter.startLeScan(scanCallback)}.subscribeOn(Schedulers.newThread()).subscribe()

正如 PhoenixWang 所建议的，BluetoothAdapter.LeScanCallback 因为他的实现而在主线程中运行。 Observable/RxJava 无法更改它。那么如何解决我的问题呢？

Answer 1

RxJava 默认是同步的。在您的情况下，它在调用者线程上运行，该线程是 Android 的主线程

您必须指定希望订阅发生的线程。

Observable.fromCallable(whatever())
        .subscribeOn(Schedulers.newThread()).subscribe()

阅读更多 here .