Телеграмм чат группы clojure

Там есть вывод типов при компиляции в байткод, чтобы избежать вызовов через рефлексию. Ну и можно тупо спросить (type x) в рантайме. Кложа же сама на джаве написана - там у всего есть вполне конкретный тип

источник

21:20пожаловаться #11

RM

Roman Melnikov in Clojure — русскоговорящее сообщество

Anton Chikin

Там есть вывод типов при компиляции в байткод, чтобы избежать вызовов через рефлексию. Ну и можно тупо спросить (type x) в рантайме. Кложа же сама на джаве написана - там у всего есть вполне конкретный тип

спасибо, попытаюсь понять

источник

21:21пожаловаться #12

KR

Kostyantin Randomname in Clojure — русскоговорящее сообщество

Оно кор, прикольно

источник

21:21пожаловаться #13

AC

Anton Chikin in Clojure — русскоговорящее сообщество

=> (type {:a 1 :b 2})
clojure.lang.PersistentArrayMap

источник

21:22пожаловаться #14

AC

Anton Chikin in Clojure — русскоговорящее сообщество

Этот класс вполне можно из джавы использовать

источник

21:22пожаловаться #15

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество

Sergey Trofimov

(defn get-items
  []
  {:items [1 2 3]
   :has-more (rand-nth [true true false])})


(defn get-items*
  [prev-result]
  (-> (get-items)
      (assoc :continue? (not (false? (:has-more prev-result))))))


(->> (iterate get-items* nil)
     (drop 1)
     (take-while :continue?)
     (mapcat :items))

сорри, этот код не рабочий, так как mapcat не ленивый 🙄

рабочий вариант получился такой

(defn get-items
  []
  {:items [1 2 3]
   :has-more (rand-nth [true true false])})

(defn get-more-items
  [prev-result]
  (when (:has-more prev-result)
    (get-items)))

(defn lazy-mapcat
  [f coll]
  (lazy-seq
    (when (seq coll)
      (concat
        (f (first coll))
        (lazy-mapcat f (rest coll))))))

(->> (iterate get-more-items (get-items))
  (take-while some?)
  (lazy-mapcat :items))

источник

23:04пожаловаться #16

DF

Dima Fomin in Clojure — русскоговорящее сообщество

Привет всем!
А какой самый быстрый способ параллельного суммирования (reduce) на сотне ядер?
У меня выходит, что DoubleAdder, и на втором месте - DoubleAdder однотредово.

источник

23:14пожаловаться #17

DF

Dima Fomin in Clojure — русскоговорящее сообщество

Столкнулся с тем, что в приложении в топ 5 пожирателей времени - шаг на котором параллельно через AtomicLong.compareAndSet обновляется некое значение - сумма показателя по миллионам контрактов. Тредов 99, и ядер 99. Отсюда видимо дикий thread contention.
Но при попытке синхронизации становится еще хуже. DoubleAccumulator/DoubleAdder - это лучший выход? Или есть еще варианты (очереди там, или еще чего)?

источник

23:14пожаловаться #18

ST

Sergey Trofimov in Clojure — русскоговорящее сообщество

Dima Fomin

Столкнулся с тем, что в приложении в топ 5 пожирателей времени - шаг на котором параллельно через AtomicLong.compareAndSet обновляется некое значение - сумма показателя по миллионам контрактов. Тредов 99, и ядер 99. Отсюда видимо дикий thread contention.
Но при попытке синхронизации становится еще хуже. DoubleAccumulator/DoubleAdder - это лучший выход? Или есть еще варианты (очереди там, или еще чего)?

в кложе для такого reducers придуманы
а так пробовать надо

источник

23:15пожаловаться #19

DF

Dima Fomin in Clojure — русскоговорящее сообщество

вот я поигрался, у меня получилось, что вот так быстрей всего на 4 домашних ядрах

источник

23:17пожаловаться #20