Можно ли как-то встроенными функциями в строке "14-17" оставить только 17 или самое простое решение str.substring(str.indexOf("-") + 1)?

Можно ли как-то встроенными функциями в строке "14-17" оставить только 17 или самое простое решение str.substring(str.indexOf("-") + 1)?

(если числа произвольные)

"14-17".split("-")[1] :D

x.substringAfter("-")

x.substringAfter("-")

Воот, спасибо, лучше всего подходит

Народ, смотрели исходники беззнаковой арифметики?

import java.math.BigInteger // In lieu of tricky code, for now just use long arithmetic.

Так что обрабатывать большие объёмы данных с её помощью я б пока не советовал

А какое отношение BigInteger имеет к большим объемам данных?

У вас количество записей в базе данных в long не помещается?

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

Но создавать объект BigInteger для каждого второго байта это оверкилл

конечно можно было бы рендер-скрипт подключить, но зависит от поставленной задачи

import java.math.BigInteger // In lieu of tricky code, for now just use long arithmetic.

Если ты о https://github.com/kotlin-graphics/kotlin-unsigned, оно к новоиспечённым родным unsigned в котлине отношения не имеет.

других реализаций я не нашёл

или код майлстоуна 1.3 не опубликован?

других реализаций я не нашёл

https://github.com/JetBrains/kotlin/blob/master/libraries/stdlib/unsigned/src/kotlin/UShort.kt

(ну и всё остальное в округе)

О, пасиб

https://github.com/Kotlin/KEEP/blob/master/proposals/inline-classes.md#type-mapping-on-jvm Inline-классы, основаннные на not-null примитиве (коим являются unsigned-ы), превращаются в примитивы. Так что оверхеда там не будет.

Всем привет. Хочу попробовать реализовать класс который будет отвечать за исполнение async и возвращать результаты в том порядке, в котором Deferred были исполнены, а не объявлены(чтобы например избежать ситуаций при которых первый Deferred может висеть 20 секунд, а остальные исполнятся за 1 секунду и нам придётся ждать выполнения первого и терять время). Собственно попробовал сделать два варианта(Kotlin 1.2.60): Первый принимает на вход коллекцию Deferred и достаёт оттуда результаты в порядке выполнения(вот код сразу с примером использования: https://pastebin.com/0HiNCmKC В этом случае всё работает корректно и Deffered выполняются параллельно, но при этом создавать коллекцию Deferred нужно заранее. Второй вариант принимает на вход коллекцию объектов с которыми необходимо провести манипуляции и функцию через которую нужно пропустить каждый из этих объектов(что синтаксически выглядит удобнее): https://pastebin.com/naT8wNWt В этом случае параллельно выполняется ровно по 3 Deffered(почему именно 3 - загадка, может там внутри какой-то тредпул из 3х тредов?) Собственно вопрос - почему во втором случае Deffered не исполняются все одновременно и как этого избежать?

Если вы хотите просто какую-то обработку делать по мере выполнения, то я бы просто подвесил реакторы класса onComplete (я не помню, как это сделать корутинами, но точно можно через CompletableFuture). Если вы хотите иметь поток, то надо использовать каналы

Если вы хотите просто какую-то обработку делать по мере выполнения, то я бы просто подвесил реакторы класса onComplete (я не помню, как это сделать корутинами, но точно можно через CompletableFuture). Если вы хотите иметь поток, то надо использовать каналы

Ну а вот чисто из интереса, почему такое поведение? Просто это выглядит как грабли на которые легко наступить

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

Ну а вот чисто из интереса, почему такое поведение? Просто это выглядит как грабли на которые легко наступить

4 процессора?

4 процессора?

Ядра? Да. Могу проверить на 8и ядерной машине, тогда он по 7 должен будет обрабатывать?

Судя по всему - да)

Вообще я так понимаю хочется сделать примерно так: fun <T> toChannel(ds: List<Deferred<T>>): Channel<Deferred<T>> Берем все deffered, и как только любой из них выполняется так или иначе - кидаем его в канал

Я посмотрел, код вообще какой-то страшный.

Вообще я так понимаю хочется сделать примерно так: fun <T> toChannel(ds: List<Deferred<T>>): Channel<Deferred<T>> Берем все deffered, и как только любой из них выполняется так или иначе - кидаем его в канал

RecieveChannel

Да я вот только неделю в языке разбираюсь

Да тут не с точки зрения языка, с точки зрения корутин что-то ужасное. То, что вы хотите - это канал, его можно сделать на корутинах путем создания селектора, который будет считывать все по очереди, хотя правильнее конечно просто при создании Deferred сразу кидать все в канал.

Да тут не с точки зрения языка, с точки зрения корутин что-то ужасное. То, что вы хотите - это канал, его можно сделать на корутинах путем создания селектора, который будет считывать все по очереди, хотя правильнее конечно просто при создании Deferred сразу кидать все в канал.

Ок, попробую изменить подход, надо только сперва понять разницу между Channel и Sequence

Последовательость - это просто обычный статическсий итерируемый объект. Канал - это в каком-то смысле аналог очереди, туда с одного конца пихаешь, с другого вынимаешь. Разница в том, что если места нет, пихалка ставится на паузу.

Вообще, идея любых асинхронных вычислений в том, что вы не обрабатываете руками момент окончания вычисления. Отлавливать в цикле момент окончания - это вообще абсурд

Звучит разумно, надо значит с каналами разобраться, ок, спасибо

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

https://www.baeldung.com/java-completablefuture

Они работают на форк-джойн пуле, так что в смысле производительности не хуже корутин

Звучит разумно, надо значит с каналами разобраться, ок, спасибо

Вот кстати в документации практически ваш пример разобран: https://github.com/Kotlin/kotlinx.coroutines/blob/master/coroutines-guide.md#selecting-deferred-values

Использовать deffered тут чтобы на него подписаться так или иначе и потом получить первым результат выглядит странным) Кажется что куда проще изначально просто на корутинах делать: fun <T> execute(fns: List<suspend () -> T>): ReceiveChannel<T> { val channel = Channel<T>(10) val count = AtomicInteger(0) val size = fns.size for (fn in fns) { launch { channel.send(fn()) if (count.incrementAndGet() == size) { channel.close() } } } return channel }

А вот так использовать: fun main(args: Array<String>) = runBlocking<Unit> { suspend fun doWork(duration: Int): String { delay(duration) return "Duration was: $duration" } val jobs = (10000 downTo 1).map { suspend { doWork(it) } } val receiveChannel = execute(jobs) runBlocking { for (s in receiveChannel) { println(s) } } }

это я согласен полностью.

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

сек

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

https://github.com/vishnyakov-aleks/WeatherApp

корутины в презентерах

Спасибо

Спасибо

fun saveUserProfile() = launch(UI) { viewState.onSaveProfileStarted() val response = withContext(DefaultDispatcher) { profileApi.saveUserSelf(user) } viewState.onSaveProfileFinished() when (response) { is OkResponse -> viewState.onSaveProfileSuccess() is ErrorResponse -> viewState.onSaveProfileError(response.error) } }

из свежего

fun saveUserProfile() = launch(UI) { viewState.onSaveProfileStarted() val response = withContext(DefaultDispatcher) { profileApi.saveUserSelf(user) } viewState.onSaveProfileFinished() when (response) { is OkResponse -> viewState.onSaveProfileSuccess() is ErrorResponse -> viewState.onSaveProfileError(response.error) } }

Так. Это получается всё что в launch уже выполняется в фоне? Или всё же нет?

Так. Это получается всё что в launch уже выполняется в фоне? Или всё же нет?

нет визконтекст в фоне

А то как из фона обращение к viewState -> view идет без падений

нет визконтекст в фоне

Ага, понял.

А то как из фона обращение к viewState -> view идет без падений

лаунч в фоне если в скобках бы не было UI

Т.е. если бы мне надо было обработать данные в фоне не затрагивая UI, достаточно было бы обернуть вызовы в launch?

Т.е. если бы мне надо было обработать данные в фоне не затрагивая UI, достаточно было бы обернуть вызовы в launch?

да

где то был хороший цикл статей на медиуме сравнения эрикса и корутин возможностей

очень прокачал меня

найду

да

Но, получается, что все функции там должны быть suspend? В данном случае в profileApi

Но, получается, что все функции там должны быть suspend? В данном случае в profileApi

нет

ERROR: S client not available

у тебя лаунч саспенд - этого достаточно

Т.е. если бы мне надо было обработать данные в фоне не затрагивая UI, достаточно было бы обернуть вызовы в launch?

https://medium.com/capital-one-developers/coroutines-and-rxjava-an-asynchronicity-comparison-part-1-asynchronous-programming-e726a925342a

а, вот оно как. мне казалось внутри всё тоже должно быть

остальные там в подвале

Это почему-то расхожее заблуждение

а, вот оно как. мне казалось внутри всё тоже должно быть

не не, это было бы плохо =)

Вообще не понятно на чем основанное

https://medium.com/capital-one-developers/coroutines-and-rxjava-an-asynchronicity-comparison-part-1-asynchronous-programming-e726a925342a

Спасибо

Спасибо

офигенный цикл, крайне советую

Вообще не понятно на чем основанное

Саспенды вызываются только из саспендов, вот оно как-то и закрутилось в голове

в продакшене пара проектов есть с корутинами, и им там хорошо.

Как бы сделать такое? Не может тип вывести при вызове. fun <T> getContextClosure(id: Int): ((Context) -> T) { val ctx = ... ... return { block: ((Context) -> T) -> block(ctx) ... } Вызвать пытаюсь так: getContextClosure(1) { ctx -> ... }

Работает только если явно указать тип дженерика и сохранить getContextClosure(1) в переменную: val f = getContextClosure<Int>(1)

Как бы сделать такое? Не может тип вывести при вызове. fun <T> getContextClosure(id: Int): ((Context) -> T) { val ctx = ... ... return { block: ((Context) -> T) -> block(ctx) ... } Вызвать пытаюсь так: getContextClosure(1) { ctx -> ... }

getContextClosure(1)({ ctx -> ... })

Ну вот оно тип не выводит

Ну вот оно тип не выводит

так а откуда оно должно его вывести без дженерика

не понимаю чет

Ну вот оно тип не выводит

возвращается же замыкание, наружней функции тип заранее не известен

Ну человек же может вывести, посмотрев)

Я так понимаю лучше дженерик перенести в замыкание?

Тогда будет ок?

Дженерик в лямбде

Ну человек же может вывести, посмотрев)

как может? не понимаю

как может? не понимаю

Вот по такой строке же можно тип сказать getContextClosure(1) { “123” }

Вот по такой строке же можно тип сказать getContextClosure(1) { “123” }

но ты её вызываешь у уже готовой кложи

вот в чем трабла

Вот по такой строке же можно тип сказать getContextClosure(1) { “123” }

Вывод типов, очевидно, должен сработать на момент вызова getContextClosure, а не после использования её результата.

Он в целом пляшет от входных параметров функции.

Так как нужную кложу веруть? Можно в лямбду дженерик вкрутить?

Перенести T внутрь лямбды