Fix #791
This commit is contained in:
1 parent
1ebbf6e349
commit
0df8e8522f
1 file changed
+2
-5
@@ -309,11 +309,8 @@ class SpiderQueenWorker(private val queen: SpiderQueen) : CoroutineScope {
|
||||
}
|
||||
|
||||
private suspend fun doInJob(index: Int) {
|
||||
val src = spiderDen.getImageSource(index) ?: run {
|
||||
delay(1000)
|
||||
mFetcherJobMap[index]?.takeIf { it.isActive }?.join()
|
||||
spiderDen.getImageSource(index)
|
||||
} ?: return
|
||||
mFetcherJobMap[index]?.takeIf { it.isActive }?.join()
|
||||
val src = spiderDen.getImageSource(index) ?: return
|
||||
val image = mSemaphore.withPermit { decode(src) }
|
||||
runCatching {
|
||||
currentCoroutineContext().ensureActive()
|
||||
|
||||
Reference in new issue
Block a user