DF
на втором месте так
Size: a a a
2020 January 10
DF
ну и классика на третьем
ST
ответ какой должен получиться?
DF
Кстати, видали fibers в Jave? Project Loom. Крутая будет штука - миллион тредов делает в полпинка. Вот только CAS от этого ничуть лучше не становится :(
DF
ответ какой должен получиться?
Какой ответ? Ну я подумал, может кто-то решал проблему с thread contention и знает способ получше LongAdder/DoubleAdder.
У меня проблема еще и в том, что сейчас приложение на Java 1.7, а там их еще не было
У меня проблема еще и в том, что сейчас приложение на Java 1.7, а там их еще не было
ST
Dima Fomin
Привет всем!
А какой самый быстрый способ параллельного суммирования (reduce) на сотне ядер?
У меня выходит, что DoubleAdder, и на втором месте - DoubleAdder однотредово.
А какой самый быстрый способ параллельного суммирования (reduce) на сотне ядер?
У меня выходит, что DoubleAdder, и на втором месте - DoubleAdder однотредово.
у тебя же в примерах не суммирование, а инкремент
он разве распараллеливается?
он разве распараллеливается?
ST
Dima Fomin
ну и классика на третьем
(time
(let [c (atom 0)
n (int 1e8)]
(dotimes [_ n]
(swap! c inc))
@c))
(time
(let [c (volatile! 0)
n (int 1e8)]
(dotimes [_ n]
(vswap! c inc))
@c))
(time
(let [c (volatile! 0)
n (int 1e8)]
(dotimes [_ n]
(vswap! c unchecked-inc-int))
@c))
"Elapsed time: 1831.561 msecs"
=> 100000000
"Elapsed time: 1238.6742 msecs"
=> 100000000
"Elapsed time: 953.5168 msecs"
=> 100000000
ST
Dima Fomin
на втором месте так
ну то есть это одного порядка
(time
(let [c (volatile! 0)
n (int 1e8)]
(dotimes [_ n]
(vswap! c unchecked-inc-int))
@c))
2020 January 11
ST
Dima Fomin
вот я поигрался, у меня получилось, что вот так быстрей всего на 4 домашних ядрах
простой цикл в основном потоке быстрее 😊
(time
(loop [i (int 0)
n (int 1e8)]
(if (pos? n)
(recur (unchecked-inc-int i) (unchecked-dec-int n))
i)))
"Elapsed time: 127.8603 msecs"
=> 100000000
ST
простой цикл в основном потоке быстрее 😊
(time
(loop [i (int 0)
n (int 1e8)]
(if (pos? n)
(recur (unchecked-inc-int i) (unchecked-dec-int n))
i)))
"Elapsed time: 127.8603 msecs"
=> 100000000
даже просто
(time
(loop [i (int 0)
n (int 1e8)]
(if (pos? n)
(recur (inc i) (dec n))
i)))
"Elapsed time: 98.6391 msecs"
=> 100000000
IP
Почему nth работает медленнее на lazy-seq, чем на векторе?
ST
Почему nth работает медленнее на lazy-seq, чем на векторе?
потому что на векторе по индексу, а в последовательности перебором от начала
IP
Каждый раз?
IP
При последовательном вызове результат предыдущего nth не кешируется?
ST
не кэшируется
"Returns the value at the index. get returns nil if index out of
bounds, nth throws an exception unless not-found is supplied. nth
also works for strings, Java arrays, regex Matchers and Lists, and,
in O(n) time, for sequences."
"Returns the value at the index. get returns nil if index out of
bounds, nth throws an exception unless not-found is supplied. nth
also works for strings, Java arrays, regex Matchers and Lists, and,
in O(n) time, for sequences."
IP
Понял, спасибо
DF
ну то есть это одного порядка
(time
(let [c (volatile! 0)
n (int 1e8)]
(dotimes [_ n]
(vswap! c unchecked-inc-int))
@c))
О! Спасибо! Не знал про операторы volatile! и vswap!
Правда в мультитреде с vswap! фигня получается, написано что он не атомарный :(
Правда в мультитреде с vswap! фигня получается, написано что он не атомарный :(
DF
даже просто
(time
(loop [i (int 0)
n (int 1e8)]
(if (pos? n)
(recur (inc i) (dec n))
i)))
"Elapsed time: 98.6391 msecs"
=> 100000000
ну это то да, в одном треде это понятно. И если сделать 100 таких тредов, тоже будет в 100 раз быстрее. Но мне то надо собрать значения из 100 тредов :/
Попробую еще из 100 тредов слать в неблокирующую очередь в один тред и в нем суммировать.
Попробую еще из 100 тредов слать в неблокирующую очередь в один тред и в нем суммировать.