我在 Kotlin 中编写了这段代码,使用协程下载一些 API 信息来下载数据。然而,代码显示了很多警告,将消息声明为“不适当的阻塞方法调用".
这是代码:
class DownloadInfoClass {
private lateinit var url: URL
private lateinit var httpURLConnection: HttpURLConnection
private lateinit var result: String
private lateinit var inputStream: InputStream
private lateinit var inputStreamReader: InputStreamReader
private var dataMap: MutableMap<String, Any> = mutableMapOf()
private fun downloadMethod(urls: String){
CoroutineScope(IO).launch {
try {
url = URL(urls)
httpURLConnection = url.openConnection() as HttpURLConnection
inputStream = httpURLConnection.inputStream
inputStreamReader = InputStreamReader(inputStream)
var data: Int = inputStreamReader.read()
while (data != -1){
val current: Char = data.toChar()
result += current
data = inputStreamReader.read()
}
}
catch (e: Exception){
e.printStackTrace()
}
}
Log.i("Result: ", result)
}
}
出现该问题的具体区域是:
URL(urls)
openConnection()
read()
谁能帮助我理解为什么会发生这种情况?我通读了 Kotlin 文档,但无法理解。另外,您能告诉我如何解决这个问题吗?
问题是,协程的构建目的只是suspend并且不阻塞线程。这意味着多个协程可以在同一个线程上运行。当使用阻塞方法时,它们会阻塞整个线程,并且可能会阻止其他协程运行。因此,这样做通常是不好的做法。
由于您显然需要调用这些方法,因此请使用尝试为每个协程创建一个新线程的调度程序,例如Dispatchers.IO
(这是为这些操作而设计的,请参阅文档 https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-dispatchers/-i-o.html)。为此,只需将阻塞调用包装起来withContext
.
withContext(Dispatchers.IO) {
// your blocking calls
}
我希望我能帮忙!
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)