1
        var i = 0
        MainScope().launch(Dispatchers.IO) {
            (1..1000).map {
                launch {
                    (1..1000).forEach {
                        i++

                    }
                }
            }.joinAll()
            logInfo("${i++}")
        }

Этот код не всегда будет выводить в результат правильное число.
Нашел 3 способа решения на сайте Котлина:

  1. использовать Atomic
    (а что, если наша переменная не примитив Атомик, а наш класс?)
  2. указать как диспатчер newSingleThreadContext. тогда все выполнится на 1-ом потоке и проблем не будет
    (пф... мы за асинхронность или где?)
  3. использовать 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++}")
        }
7
  • 2
    Чудес не бывает, mutex фактически симулирует исполнение в одном треде, поэтому так медленно. Реальная асинхронность будет видна только в случае длинных вычислений и коротких записей результата. У вас же 100% времени это запись результата, вот и получается неэффективно. Это как хоть 100 грузчиков нанять, если дверь в склад на одного, быстро разгрузить не выйдет. 1 ноя 2022 в 15:33
  • Из аналогии с грузчиками вылазит еще одна подсказка - делайте больше дверей :) Распараллеливайте результат. 1 ноя 2022 в 15:35
  • @EugeneKrivenja но ведь даже через newSingleThreadContext получается быстрее (( а есть еще решения, кроме этих 3 (2 их которых сомнительные)?
    – Wlad
    1 ноя 2022 в 15:35
  • 1
    Вот возможно вам подойдет. В Котлине реального опыта нет, в Go отлично применяется для мультипоточного взаимодействия. Хоть миллион потоков пишет, один читает и никаких блокировок. kotlinlang.org/docs/channels.html 1 ноя 2022 в 15:43
  • 1
    А просто synchronized блок для i++ использовать? Не быстрее Mutex будет?
    – BccHnw
    2 ноя 2022 в 5:35

1 ответ 1

0
 viewModelScope.launch(Dispatchers.IO) {
                (1..10000).map {
                    launch {
                        (1..10000).forEach {
                            @Synchronized
                            fun go() {
                                i++
                            }
                            go()
                        }
                    }
                }.joinAll()
                logInfo("${i}")
            }

Вариант с @Synchronized работает отлично и быстрее Mutex

5
  • А зачем? Atomic класс будет быстрее и лучше. И зачем тут в функцию обёрнуто, есть функция synchronized() { }. К тому же synchronized блочит поток, а mutex нет
    – IR42
    2 ноя 2022 в 14:10
  • что делать в ситуации, когда это мой класс, а не AtomicInteger? mutex очень долго выполняет код
    – Wlad
    2 ноя 2022 в 15:27
  • Разные ситуации - разные инструменты. Synchronized не замена Mutex, у них разный принцип работы в корутинах. И не такой Mutex и медленный, в данной задаче может и медленней Synchronized, но это не означает, что он в другой задаче будет хуже.
    – IR42
    2 ноя 2022 в 17:23
  • К тому же никто не мешает реализовать свой алгоритм синхронизации для вашего кастомного класса (Compare and Swap например, как в Atomic классах)
    – IR42
    2 ноя 2022 в 17:29
  • @IR42 а можно подробнее: в чем разница между Mutex и Synchronized? а то пока не оч понятно когда что надо использовать
    – Wlad
    2 ноя 2022 в 17:42

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.