Профит от многопоточности на простом примере?

Question

[Berry90]

Многопото́чность слабо понимаю, набросал код на тредах (kotlin)

val start = System.currentTimeMillis()

var arrayStart = mutableListOf<String>()
var arrayResult = mutableListOf<String>()
var arrayHelper1 = mutableListOf<String>()
var arrayHelper2 = mutableListOf<String>()


repeat(3_000_000) {
      arrayStart.add((it * 2).toString())
}

val thread1 = Thread(
        Runnable {
            for (i in 0 until arrayStart.size/2-3 step 3) {
                val t = arrayStart.subList(i, i+3)
                arrayHelper1.addAll(0, t.reversed())
            }
        }
    )

val thread2 = Thread(
        Runnable {
            for (i in arrayStart.size/2..arrayStart.size-3 step 3) {
                val t = arrayStart.subList(i, i+3)
                arrayHelper2.addAll(0, t.reversed())
            }
        }
    )

thread1.start()
thread2.start()
thread1.join()
thread2.join()

arrayResult.addAll(arrayHelper1)
arrayResult.addAll(arrayHelper2)

val time = (System.currentTimeMillis() - start) / 1000
println("time: $time")

и код без тредов

val start = System.currentTimeMillis()

var arrayStart = mutableListOf<String>()
var arrayResult = mutableListOf<String>()
var arrayHelper1 = mutableListOf<String>()
var arrayHelper2 = mutableListOf<String>()

repeat(3_000_000) {
      arrayStart.add((it * 2).toString())
}

for (i in 0 until arrayStart.size/2-3 step 3) {
      val t = arrayStart.subList(i, i+3)
      arrayHelper1.addAll(0, t.reversed())
}

for (i in arrayStart.size/2..arrayStart .size-3 step 3) {
     val t = arrayStart.subList(i, i+3)
     arrayHelper2.addAll(0, t.reversed())
}

arrayResult.addAll(arrayHelper1)
arrayResult.addAll(arrayHelper2)

val time = (System.currentTimeMillis() - start) / 1000
println("time: $time")

оба кода выполнились за ~300 секунд, как нужно написать код чтоб была видна разница?

Comments

[Артем Черепахин]

Начните поиски с простого. Замерьте сколько выполняется каждый по отдельности кусок. Возможно большую часть из 300 сек. выполняется

repeat(3_000_000) {
      arrayStart.add((it * 2).toString())
}

[Berry90]

Артем Черепахин, этот кусок кода выполняется моментально за 0 секунд

Answer 1

[Dimonchik]

память смотреть

Comments

[Berry90]

посмотрел в таск менеджере виндовз, памяти съедаются одинаково

[Dimonchik]

))))))))))))))))))))))))))))))))))))))))))))))))))

ну тогда "зачем платить больше"

бухгалтеру так на счета Амазона и скажете

[xmoonlight]

dimonchik2013, Жжошь!)))

Answer 2

[mayton2019]

Это очень опасный пример. Он завязан на фазы уборки мусора. Прогрев JIT. И размер кешей. В зависимости он версий java и ос. И никакой синьор-помидор тут не сможет точно сказать какие переходные процессы текут во 2 варианте кода.

Как переписать - я не знаю. Но мультипоточка всегда полезна при парсинге множества сайтов одновременно. Вот пускай автор сделает веб краулер.

Comments

[Berry90]

действительно результаты разнятся в зависимости от версии jvm
opendJDK 15 - без тредов: 16, с тредами: 16
opendJDK 14/oracleJDK 14 - без тредов: 16, с тредами: 21
oracleJDK 13 - без тредов: 15, с тредами: 9
GraalVM 20(java 11) - без тредов: 19, с тредами: 11

Answer 3

[koperagen]

Взять и написать параллельный код на тредах не так уж тривиально. Лучше берите Stream API, с его помощью сортировки, map-reduce операции и много чего ещё отлично ускоряется кратно количеству ядер.

Comments

[mayton2019]

Не согласен с посылом. Автор ведь не это спрашивает. Стримы имеют узкое назначение. И хотя они как Тьюрингова машина обладают полнотой - но некоторые задачи на них скорее всего будут архитектурно некрасивы. Так-же как и не очень красиво выглядит отработка исключений внутри стрима.

Попробуйте взять web-crawler и переписать его на стримах.