Кстати, а из тех ктo испoльзует Rx, ктo какoгo пoдхoда с oшибками пpидеpживается: Observable<T> или Observable<Either<Throwable, T>> Частo видел oсoбеннo в библиoтечках всяких испoльзoвание oбеpтoк типа Result вместo Either и пp. Пpи этoм каких-тo oчевидных пpеимуществ этo ведь не дает, кpoме вoзмoжнoсти не наследoвать Throwable в oшибках.

Channel<SuccessOrFailure<T>> ?

Но вот в коррутинах, которые призваны сделать асинхронный код синхроныый, неплохо использовать try catch... Получается в случае Result отказываешься от этой фичи

но тогда либо нужно везде не забывать onErrorReturn(), либо обрабатывать exception и в Either, и в виде чистого exception

Either жеш должен явно показывать, что кроме типа Left никаких ошибок быть не может в принципе

https://github.com/Kotlin/kotlinx.coroutines/releases/tag/0.25.0 очень крутой релиз, из нового поддежка thread local данных, перелопатили обработку исключений в корутинах и IO пул добавили

https://github.com/Kotlin/kotlinx.coroutines/releases/tag/0.25.0 очень крутой релиз, из нового поддежка thread local данных, перелопатили обработку исключений в корутинах и IO пул добавили

А чем полезен IO пул? (Вопрос от нуба)

А чем полезен IO пул? (Вопрос от нуба)

ио блокирую треды

а блокировать треды из комонпул так себе

а блокировать треды из комонпул так себе

При чём тут блокировка? Корутины же не про блокировку тредов...

А чем полезен IO пул? (Вопрос от нуба)

Для ведра он, очевидно же. Где у нас ещё Java 6 ?‍♀

Для ведра он, очевидно же. Где у нас ещё Java 6 ?‍♀

Ты не поверишь (: существуют такие места (:

При чём тут блокировка? Корутины же не про блокировку тредов...

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

Для ведра он, очевидно же. Где у нас ещё Java 6 ?‍♀

ну JDBC драйвера во всех джавах

При чём тут блокировка? Корутины же не про блокировку тредов...

магии нет, ты все равно используешь треды

С бoльшoй дoлей веpoятнoсти где-тo нужен явный тайп-каст UPD: да, глянул, дoбавьте тайп-касты explicit, испpавится

Не понял, куда надо что добавить

Для ведра он, очевидно же. Где у нас ещё Java 6 ?‍♀

Я имел ввиду, чем io пул отличается от common пула?

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

Ммм... Не знал. Спасибо.

Я имел ввиду, чем io пул отличается от common пула?

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

Я имел ввиду, чем io пул отличается от common пула?

У него больше тредов, up to 64, или больше если больше процессоров на машине)

У него больше тредов, up to 64, или больше если больше процессоров на машине)

Понял.) А у common пулла сколько потоков? (В Гугле не забанили, не нашёл эту инфу)

Сколько ядер , столько и потоков

Типо того, +- 1

Сколько ядер , столько и потоков

Ну сказали что io имеет 64 потока. Значит у common было меньше

А у вас 64 ядра на машине?

Ну сказали что io имеет 64 потока. Значит у common было меньше

у тебя 64 ядра ?

А у вас 64 ядра на машине?

Нет.

У меня 8. На io бывает блочится

В документации не сказано сколько, но сказано, что он обертывает дефолтный ForkJoinPool, а там сколько потоков

ну JDBC драйвера во всех джавах

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

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

вроде еще не увсех

У меня 8. На io бывает блочится

Я всё равно не понял. IO пул использует блокировку? Или что? Можете более развернуто объяснить, пожалуйста?

Я пока не дочитал :)

Нет, это просто альтернативный пул с бОльшим количеством потоков.

Я всё равно не понял. IO пул использует блокировку? Или что? Можете более развернуто объяснить, пожалуйста?

это лучше почитать

ричем есть хорошие доклады, правда джавовые

Смысл в том, что все потенциально блокирующие io операции выделяются в отдельный большой пул. Если он блочится, то не страшно, поскольку основной пул живет

Смысл в том, что все потенциально блокирующие io операции выделяются в отдельный большой пул. Если он блочится, то не страшно, поскольку основной пул живет

Хм... Т.е. если я иду в сеть или бд, то вместо launch лучше launch(IO)?

ага

Нет, зависит от API

Сеть обычно асинхронная. Так что скорее в файл или бд

если API асинхронный, то IO не ненужен

Хм... Т.е. если я иду в сеть или бд, то вместо launch лучше launch(IO)?

ну есть NIO и асинхроные дравера для бд

но в Андроиде вроде небыло NIO

но в Андроиде вроде небыло NIO

с API 26 добавили

если API асинхронный, то IO не ненужен

Ну например в андройде я делаю что-то типа launch(UI) { //что-то withContext(DefaultDispatcher) { // запрос в сеть или бд } //что-то }

если API асинхронный, то IO не ненужен

Может наоборот?

Может наоборот?

исправился

Ну например в андройде я делаю что-то типа launch(UI) { //что-то withContext(DefaultDispatcher) { // запрос в сеть или бд } //что-то }

ну например если используешь синхронный вариант okhttp - то используй IO, а если асинхронный okhttp - то любой подойдет

ну например если используешь синхронный вариант okhttp - то используй IO, а если асинхронный okhttp - то любой подойдет

Ну, я вообще не использую в этом проекте okhttp. :))

ну блин, я даже пример привел близкий андроиду) в общем не важно что, важно какой API, синхронный - что означает что он блокирует тред на котором ранается корутина, или асинхронный - т.е. неблокирующий текущий тред

okhttp так-то тоже поверх тред пула, но у него есть асинхронный API

okhttp так-то тоже поверх тред пула, но у него есть асинхронный API

Понятно

Окей, спасибо.)

Т.е. получается что с withContext, в моём случае, лучше IO.

Я честно говоря пока не понял в чем большое приемущество нового IO перед простым cachedThreadPool https://github.com/Heapy/tgto/blob/master/src/main/kotlin/app/hea/tgto/coroutines/Contexts.kt#L36 сс @relizarov

Он кроссплатформенный ? И наверное delay обрабатывает более оптимизироаанно.

добрый день прошу помощи хочу реализовать на котлин js работу с bluetooth https://developer.mozilla.org/en-US/docs/Web/API/Bluetooth но не понимаю как , можете подсказать?

Если не нашёл ответа можешь спросить тут: @kotlin_js

"cause": { "arg0": [ "должно соответствовать шаблону \"^[0-9a-zA-Z]{1,64}$\"" ] }

"cause": { "itemId": [ "должно соответствовать шаблону \"^[0-9a-zA-Z]{1,64}$\"" ] }

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

разве можно на интерфейс вешать @RestController ?

разве можно на интерфейс вешать @RestController ?

Да, работает

https://stackoverflow.com/questions/8002514/spring-mvc-annotated-controller-interface-with-pathvariable

ERROR: S client not available

Да, работает

работает но как

спринг он такой...

Щас задумался... Корутины запускаются в тред пуле. Тред пул имеет очередь задаваемых действий, сначала выполняет текущие действия, а потом выполняет другие. По идее как, пока не закончит текущие - он не может начать новые. Как тогда выполняется такой код? val list = List(1000) { launch { delay(1000) print(".") } } list.forEach { it.join() } Я правильно понимаю, что когда он видит delay, тред пул откладывает вычисления, берёт следующие, а потом проверяет старые?

Щас задумался... Корутины запускаются в тред пуле. Тред пул имеет очередь задаваемых действий, сначала выполняет текущие действия, а потом выполняет другие. По идее как, пока не закончит текущие - он не может начать новые. Как тогда выполняется такой код? val list = List(1000) { launch { delay(1000) print(".") } } list.forEach { it.join() } Я правильно понимаю, что когда он видит delay, тред пул откладывает вычисления, берёт следующие, а потом проверяет старые?

тредполл - набор тредов

тредполл - набор тредов

Ну окей, не тредпул, а экзекьютер.)

тред пул "назначает" задание каждому треду

это очень отдаленно

Ну окей, не тредпул, а экзекьютер.)

тебе нужно послушать про корунтины доклад от @relizarov

Щас задумался... Корутины запускаются в тред пуле. Тред пул имеет очередь задаваемых действий, сначала выполняет текущие действия, а потом выполняет другие. По идее как, пока не закончит текущие - он не может начать новые. Как тогда выполняется такой код? val list = List(1000) { launch { delay(1000) print(".") } } list.forEach { it.join() } Я правильно понимаю, что когда он видит delay, тред пул откладывает вычисления, берёт следующие, а потом проверяет старые?

> По идее как, пока не закончит текущие - он не может начать новые

работает но как

Скорее всего идёт изучать вглубь, есть вроде метод получения аннотаций родителя, комп не под рукой но должно быть не сложно

> По идее как, пока не закончит текущие - он не может начать новые

представь ты Барин, у тебя крепосные, тебе приходит сделать то то и то, ты раздаешь приказы своим крепосным, но ты можешь скасть "Ей ты пойди помоги, или сделай то-то, а потом продолжай свою работу"

Скорее всего идёт изучать вглубь, есть вроде метод получения аннотаций родителя, комп не под рукой но должно быть не сложно

не думаю, и ответ стековерфлов с таким ответом

представь ты Барин, у тебя крепосные, тебе приходит сделать то то и то, ты раздаешь приказы своим крепосным, но ты можешь скасть "Ей ты пойди помоги, или сделай то-то, а потом продолжай свою работу"

Я понимаю, что именно так и работают корутины, но мне интересно, как это реализовывается

не думаю, и ответ стековерфлов с таким ответом

Кстати, аннотация может быть наследуемой, скорее всего именно так и работает

вставлю 5 копеек: можешь просто писать@PathVariable itemId: String, спринг поймёт имя

вставлю 5 копеек: можешь просто писать@PathVariable itemId: String, спринг поймёт имя

+

Кстати, аннотация может быть наследуемой, скорее всего именно так и работает

нет

как и @RequestParam, @RequestHeader и @CookieValue (вроде так)

Я понимаю, что именно так и работают корутины, но мне интересно, как это реализовывается

ну тут начинается сложные штуки, но вроде пока инфу не разглашают

вставлю 5 копеек: можешь просто писать@PathVariable itemId: String, спринг поймёт имя

В java 8, и то если метаинфориация не затирается флагами компиляции

Щас задумался... Корутины запускаются в тред пуле. Тред пул имеет очередь задаваемых действий, сначала выполняет текущие действия, а потом выполняет другие. По идее как, пока не закончит текущие - он не может начать новые. Как тогда выполняется такой код? val list = List(1000) { launch { delay(1000) print(".") } } list.forEach { it.join() } Я правильно понимаю, что когда он видит delay, тред пул откладывает вычисления, берёт следующие, а потом проверяет старые?

Тредпул просто гоняет код, он не решает, когда и что откладывать. За планирование выполнения корутин отвечает https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.experimental/-coroutine-dispatcher/index.html Именно он при выполнении suspend-функции, коей является delay, приостанавливает текущую корутину и запускает следующую из очереди -- на тредпуле (CommonPool), на текущем потоке (Unconfined), в UI-потоке с помощью соответствующего планировщика (UI) etc.

В java 8, и то если метаинфориация не затирается флагами компиляции

так там код вообще на котлине

И что? Эта фишка джавы и она появилась в 8ке

В java 8, и то если метаинфориация не затирается флагами компиляции

тогда поидее вообще бы не работало, и смысл аннотаций 0

ведь их не будет по факту

Тредпул просто гоняет код, он не решает, когда и что откладывать. За планирование выполнения корутин отвечает https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines.experimental/-coroutine-dispatcher/index.html Именно он при выполнении suspend-функции, коей является delay, приостанавливает текущую корутину и запускает следующую из очереди -- на тредпуле (CommonPool), на текущем потоке (Unconfined), в UI-потоке с помощью соответствующего планировщика (UI) etc.

Спасибо!)

Спасибо!)

Ну и да, доклады Романа Елизарова, упомянутые выше, действительно очень хороши.

Ну и да, доклады Романа Елизарова, упомянутые выше, действительно очень хороши.

Я смотрел, кажется, все его доклады про корутины. Но, похоже, этот момент я провтыкал...

Подскажите, а есть способ включить в идее подсказки методов репозиториев в Jpa, как в java?

Вот так завелось: <plugin> <groupId>org.jetbrains.kotlin</groupId> <artifactId>kotlin-maven-plugin</artifactId> <configuration> <args> <arg>-java-parameters</arg> </args> </configuration> </plugin>