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

2020 December 09

D

ну например я сейчас попробовал val c = newFixedThreadPoolContext(nThreads = 1) и сделал цикл с launch(c) { .. } он запустил их не 1 штуку, а все 30 xd

Одну запустил, остальные поставил в очередь.

источник

17:33пожаловаться #1

@

@vffuunnyy in Kotlin Community

Pavel Erokhin

Какие? может мы сможем тебя отговорить

не сможете xd, я сам не смогу ибо они не от меня зависят, ограничения у штуки с которой я работаю на 200 запросов

источник

17:33пожаловаться #2

D

Dmitry in Kotlin Community

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

источник

17:34пожаловаться #3

@

@vffuunnyy in Kotlin Community

Dmitry

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

нельзя эксепнш, нужно именно очередь :)

источник

17:34пожаловаться #4

@

@vffuunnyy in Kotlin Community

200 работают, остальные ждут своего часа. вот так вот
Как это реализовать на каналах не совсем понимаю

источник

17:34пожаловаться #5

с#

саша сок #KotlinGang... in Kotlin Community

@vffuunnyy

200 работают, остальные ждут своего часа. вот так вот
Как это реализовать на каналах не совсем понимаю

я писал для этого свой класс

источник

17:35пожаловаться #6

с#

саша сок #KotlinGang... in Kotlin Community

основная идея через каналы

источник

17:35пожаловаться #7

с#

саша сок #KotlinGang... in Kotlin Community

@vffuunnyy

200 работают, остальные ждут своего часа. вот так вот
Как это реализовать на каналах не совсем понимаю

мне не только в самом классе надо было отслежвивать запущенные / остановленные Job'ы, поэтому вынес в отдельный класс.

https://gist.github.com/y9san9/1ba076d8123f4f09dc02a1c73873ff03

мне не только в самом классе надо было отслежвивать запущенные / остановленные Job'ы, поэтому вынес в отдельный класс.

https://gist.github.com/y9san9/1ba076d8123f4f09dc02a1c73873ff03

val sync = Synchronizer(maxParallelBlocks = 10)
sync.runInQueue {

}

Gist

Synchronizer.kt

GitHub Gist: instantly share code, notes, and snippets.

источник

17:41пожаловаться #8

AL

Anton Lakotka in Kotlin Community

@vffuunnyy

не понимаю как это выглядеть должно 🤔

https://pl.kotl.in/2_205fG0r

источник

17:41пожаловаться #9

@

@vffuunnyy in Kotlin Community

Спасибо зайки🐤

источник

17:41пожаловаться #10

AL

Anton Lakotka in Kotlin Community

Anton Lakotka

https://pl.kotl.in/2_205fG0r

это в самом примитивном виде. но можно решать разными способами

источник

17:41пожаловаться #11

с#

саша сок #KotlinGang... in Kotlin Community

Anton Lakotka

https://pl.kotl.in/2_205fG0r

о, вот тут прикольно реализованно, только результат и эксепшон из джобы не получить, но я не знал про то, что отправка в канал суспендится, если он заполнен

источник

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

AL

Anton Lakotka in Kotlin Community

> только результат и эксепшон из джобы не получить
получить. если захотеть

источник

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

с#

саша сок #KotlinGang... in Kotlin Community

Anton Lakotka

> только результат и эксепшон из джобы не получить
получить. если захотеть

я про вашу реализацию, у меня тут так и есть
https://t.me/kotlin_lang/218836

Alex Sokol in Kotlin Community

мне не только в самом классе надо было отслежвивать запущенные / остановленные Job'ы, поэтому вынес в отдельный класс.

https://gist.github.com/y9san9/1ba076d8123f4f09dc02a1c73873ff03

мне не только в самом классе надо было отслежвивать запущенные / остановленные Job'ы, поэтому вынес в отдельный класс.

https://gist.github.com/y9san9/1ba076d8123f4f09dc02a1c73873ff03

val sync = Synchronizer(maxParallelBlocks = 10)
sync.runInQueue {

}

источник

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

AA

Anton Arhipov in Kotlin Community

Denys

А это какая-то внутренняя утилита для документации? Или в пайплайне используется готовый генератор статических сайтов?

внутренняя тулзовина. На ней почти вся документация сделана в JB

источник

17:47пожаловаться #15

AL

Anton Lakotka in Kotlin Community

саша сок #KotlinGang

я про вашу реализацию, у меня тут так и есть
https://t.me/kotlin_lang/218836

Alex Sokol in Kotlin Community

мне не только в самом классе надо было отслежвивать запущенные / остановленные Job'ы, поэтому вынес в отдельный класс.

https://gist.github.com/y9san9/1ba076d8123f4f09dc02a1c73873ff03

мне не только в самом классе надо было отслежвивать запущенные / остановленные Job'ы, поэтому вынес в отдельный класс.

https://gist.github.com/y9san9/1ba076d8123f4f09dc02a1c73873ff03

val sync = Synchronizer(maxParallelBlocks = 10)
sync.runInQueue {

}

ну просто я не задавался целью еще и получать результат в своем примере.
всегда можно объявить либо 2-й канал с результатами, либо просто дергать вторую лямбду куда передавать результаты

источник

17:49пожаловаться #16

D

Denys in Kotlin Community

Anton Arhipov

внутренняя тулзовина. На ней почти вся документация сделана в JB

Очень круто! Планируете выпустить в мир как-то? :)

источник

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

AA

Anton Arhipov in Kotlin Community

Denys

Очень круто! Планируете выпустить в мир как-то? :)

Не в курсе о таких планах. Этот инструмент кажется на столько заточен под жб, что может быть не имеет смысла.

Но может быть я ошибаюсь и оно уже открыто, надо поспрашивать

источник

17:56пожаловаться #18

AN

Alexander Nozik in Kotlin Community

Сатанистов хотели? Сатанисты пришли: https://blog.jetbrains.com/kotlin/2020/12/deep-learning-with-kotlin-introducing-kotlindl-alpha/

JetBrains Blog

Deep Learning With Kotlin: Introducing KotlinDL-alpha – Kotlin Blog | JetBrains

Hi folks!
Today we would like to share with you the first preview of KotlinDL (v.0.1.0), a high-level Deep Learning framework written in Kotlin and inspired by Keras. It offers simple APIs for buildin

источник

17:56пожаловаться #19

OY

Oleg Yukhnevich in Kotlin Community

Anton Lakotka

https://pl.kotl.in/2_205fG0r

https://pl.kotl.in/rwTBbO8Cr

Вот вариант с семафором, если вдруг что

источник

18:00пожаловаться #20