Я хочу реализовать классический механизм тайм-аута Bluetooth и повтора ошибок с помощью сопрограммы, я написал код ниже. Это дает мне тайм-аут каждые десять секунд вместо каждых 5 секунд.
suspend fun connectClassicBluetoothDevice() {
repeat(5) {
try {
withTimeout(5000) {
withContext(Dispatchers.IO) {
ensureActive()
println("${Date(System.currentTimeMillis())}: Coroutine is running $it")
suspendCancellableCoroutine { continuation ->
continuation.resume(blockCall())
continuation.invokeOnCancellation {
// call the BluetoothSocket.close() will immediately interrupt the blockCall()
// BluetoothSocket.close()
println("${Date(System.currentTimeMillis())}: Coroutine is cancelled")
}
}
}
}
} catch (e: TimeoutCancellationException) {
println("${Date(System.currentTimeMillis())}: timeout")
}
}
}
private fun blockCall() = try {
// it is a block call that maybe takes 10 seconds to complete
// BluetoothSocket.connect()
true
} catch (e: Exception) {
println("${Date(System.currentTimeMillis())}: exception")
false
}
Когда я меняю его на приведенный ниже код, у меня все работает хорошо, тайм-аут будет вовремя. Меня смущает, почему в приведенном выше коде тайм-аут не приходит вовремя. Так как же исправить ошибку в приведенном выше коде?
suspend fun connectClassicBluetoothDevice() {
repeat(5) {
try {
withTimeout(5000) {
ensureActive()
println("${Date(System.currentTimeMillis())}: Coroutine is running $it")
suspendCancellableCoroutine { continuation ->
thread {
continuation.resume(blockCall())
}
continuation.invokeOnCancellation {
// call the BluetoothSocket.close() will immediately interrupt the blockCall()
// BluetoothSocket.close()
println("${Date(System.currentTimeMillis())}: Coroutine is cancelled")
}
}
}
} catch (e: TimeoutCancellationException) {
println("${Date(System.currentTimeMillis())}: timeout")
}
}
}
private fun blockCall() = try {
// it is a block call that maybe takes 10 seconds to complete
// BluetoothSocket.connect()
true
} catch (e: Exception) {
println("${Date(System.currentTimeMillis())}: exception")
false
}
Подробнее здесь: https://stackoverflow.com/questions/791 ... ith-corout
Как реализовать классический механизм тайм-аута Bluetooth и повтора ошибок с помощью сопрограммы ⇐ Android
Форум для тех, кто программирует под Android
1731461861
Anonymous
Я хочу реализовать классический механизм тайм-аута Bluetooth и повтора ошибок с помощью сопрограммы, я написал код ниже. Это дает мне тайм-аут каждые десять секунд вместо каждых 5 секунд.
suspend fun connectClassicBluetoothDevice() {
repeat(5) {
try {
withTimeout(5000) {
withContext(Dispatchers.IO) {
ensureActive()
println("${Date(System.currentTimeMillis())}: Coroutine is running $it")
suspendCancellableCoroutine { continuation ->
continuation.resume(blockCall())
continuation.invokeOnCancellation {
// call the BluetoothSocket.close() will immediately interrupt the blockCall()
// BluetoothSocket.close()
println("${Date(System.currentTimeMillis())}: Coroutine is cancelled")
}
}
}
}
} catch (e: TimeoutCancellationException) {
println("${Date(System.currentTimeMillis())}: timeout")
}
}
}
private fun blockCall() = try {
// it is a block call that maybe takes 10 seconds to complete
// BluetoothSocket.connect()
true
} catch (e: Exception) {
println("${Date(System.currentTimeMillis())}: exception")
false
}
Когда я меняю его на приведенный ниже код, у меня все работает хорошо, тайм-аут будет вовремя. Меня смущает, почему в приведенном выше коде тайм-аут не приходит вовремя. Так как же исправить ошибку в приведенном выше коде?
suspend fun connectClassicBluetoothDevice() {
repeat(5) {
try {
withTimeout(5000) {
ensureActive()
println("${Date(System.currentTimeMillis())}: Coroutine is running $it")
suspendCancellableCoroutine { continuation ->
thread {
continuation.resume(blockCall())
}
continuation.invokeOnCancellation {
// call the BluetoothSocket.close() will immediately interrupt the blockCall()
// BluetoothSocket.close()
println("${Date(System.currentTimeMillis())}: Coroutine is cancelled")
}
}
}
} catch (e: TimeoutCancellationException) {
println("${Date(System.currentTimeMillis())}: timeout")
}
}
}
private fun blockCall() = try {
// it is a block call that maybe takes 10 seconds to complete
// BluetoothSocket.connect()
true
} catch (e: Exception) {
println("${Date(System.currentTimeMillis())}: exception")
false
}
Подробнее здесь: [url]https://stackoverflow.com/questions/79180642/how-to-implement-classic-bluetooth-timeout-and-error-retry-mechanism-with-corout[/url]
Ответить
1 сообщение
• Страница 1 из 1
Перейти
- Кемерово-IT
- ↳ Javascript
- ↳ C#
- ↳ JAVA
- ↳ Elasticsearch aggregation
- ↳ Python
- ↳ Php
- ↳ Android
- ↳ Html
- ↳ Jquery
- ↳ C++
- ↳ IOS
- ↳ CSS
- ↳ Excel
- ↳ Linux
- ↳ Apache
- ↳ MySql
- Детский мир
- Для души
- ↳ Музыкальные инструменты даром
- ↳ Печатная продукция даром
- Внешняя красота и здоровье
- ↳ Одежда и обувь для взрослых даром
- ↳ Товары для здоровья
- ↳ Физкультура и спорт
- Техника - даром!
- ↳ Автомобилистам
- ↳ Компьютерная техника
- ↳ Плиты: газовые и электрические
- ↳ Холодильники
- ↳ Стиральные машины
- ↳ Телевизоры
- ↳ Телефоны, смартфоны, плашеты
- ↳ Швейные машинки
- ↳ Прочая электроника и техника
- ↳ Фототехника
- Ремонт и интерьер
- ↳ Стройматериалы, инструмент
- ↳ Мебель и предметы интерьера даром
- ↳ Cантехника
- Другие темы
- ↳ Разное даром
- ↳ Давай меняться!
- ↳ Отдам\возьму за копеечку
- ↳ Работа и подработка в Кемерове
- ↳ Давай с тобой поговорим...
Мобильная версия