var i = 0
MainScope().launch(Dispatchers.IO) {
(1..1000).map {
launch {
(1..1000).forEach {
i++
}
}
}.joinAll()
logInfo("${i++}")
}
Этот код не всегда будет выводить в результат правильное число.
Нашел 3 способа решения на сайте Котлина:
- использовать
Atomic
(а что, если наша переменная не примитив Атомик, а наш класс?) - указать как диспатчер
newSingleThreadContext
. тогда все выполнится на 1-ом потоке и проблем не будет
(пф... мы за асинхронность или где?) - использовать
Mutext
(работет, но сиииильно снижает скорость выполнения кода)
подскажите: как правильно поступать в такой ситуации?
p.s. рабочий, но медленный код с Mutex (может тут, что можно поправить?)
var i = 0
val mutex = Mutex()
MainScope().launch(Dispatchers.IO) {
(1..1000).map {
launch {
(1..1000).forEach {
mutex.withLock {
i++
}
}
}
}.joinAll()
logInfo("${i++}")
}
synchronized
блок дляi++
использовать? Не быстрееMutex
будет?