使用RxAndroidBle进行蓝牙 LE 连接。它可以扫描和识别具有给定服务 UUID 的设备(并将它们添加到向量中)。但是当我在 while 循环中添加一个自旋锁(实际上是一个AtomicBoolean
)来检测扫描何时完成时,它似乎不再找到设备。
public void scanForScopes() {
Log.d( LOG_TAG, "Entered scanForScopes()" );
rxBleDeviceVector.clear( );
asDeviceVector.clear( );
// since we added time and device count limits, we know this Observable will not run forever
scanSubscriber = new AsScanSubscriber<>( );
scanSubscription = asBleClient
.scanBleDevices( asServiceIdArray )
.subscribeOn( Schedulers.io() )
.observeOn( AndroidSchedulers.mainThread( ) )
.take( MAX_SCOPES )
.take( SCAN_TIME, TimeUnit.SECONDS )
.doOnNext( this::addRxBleScanResult ) // works
.doOnCompleted( () -> Log.d( LOG_TAG, "Scan for scope devices has completed" ) ) // doesn't seem to be called
.subscribe( scanSubscriber ); // calls scanSubscriber.onStart() (which sets nowScanning true)
我怀疑可能发生了几件事:
- 主 UI 线程已向前推进并试图显示已发现设备的空向量。如果是这种情况,我怎样才能让它等待设备扫描完成而不会使系统陷入困境?我认为 RxJava 平台消除了这个
AsyncTask
选项。 - 测试扫描完成的
while()
循环可能会消耗过多的 CPU 周期,从而阻止扫描成功。我怎样才能解决这个问题?