I
Size: a a a
2020 December 02
КР
Я пытаюсь придумать, как Msg засунуть в некоторую очередь в том порядке, в котором он пришёл.
КР
Понятно что можно всякими Synchronized и прочими блокировками, но хочется как-то без блокировок обойтись.
O
Ну а ченелы и флоу почему не заюзать?
КР
Ну а ченелы и флоу почему не заюзать?
Ты гист смотрел?)
O
Ты гист смотрел?)
неа
I
@angmarr @themishkun
Господа tea-шники, как вы в своих либах реализуете синхронную обработку msg?
https://gist.github.com/indrih17/c58d28d01f4016576e644906ed6f4295#file-feature-kt-L65
В любом случае, если диспатчить msg в launch, в некоторых ситуациях порядок msg нарушается. Могу сделать буфер в
Господа tea-шники, как вы в своих либах реализуете синхронную обработку msg?
https://gist.github.com/indrih17/c58d28d01f4016576e644906ed6f4295#file-feature-kt-L65
В любом случае, если диспатчить msg в launch, в некоторых ситуациях порядок msg нарушается. Могу сделать буфер в
SharedFlow и просто tryEmit, но такое себе.
Ну получается что тут вопрос скорее про примитивы kotlin coroutine
Ту я хз, а как sharedflow работает я даже не разбирался
Ту я хз, а как sharedflow работает я даже не разбирался
КР
Ну получается что тут вопрос скорее про примитивы kotlin coroutine
Ту я хз, а как sharedflow работает я даже не разбирался
Ту я хз, а как sharedflow работает я даже не разбирался
Не обязательно. Вдруг вы в своих либах решили другими способами и можно решить без корутин.
ML
@angmarr @themishkun
Господа tea-шники, как вы в своих либах реализуете синхронную обработку msg?
https://gist.github.com/indrih17/c58d28d01f4016576e644906ed6f4295#file-feature-kt-L65
В любом случае, если диспатчить msg в launch, в некоторых ситуациях порядок msg нарушается. Могу сделать буфер в
Господа tea-шники, как вы в своих либах реализуете синхронную обработку msg?
https://gist.github.com/indrih17/c58d28d01f4016576e644906ed6f4295#file-feature-kt-L65
В любом случае, если диспатчить msg в launch, в некоторых ситуациях порядок msg нарушается. Могу сделать буфер в
SharedFlow и просто tryEmit, но такое себе.у меня обработка вся на мейн треде. ты чёт переинжиниришь
КР
у меня обработка вся на мейн треде. ты чёт переинжиниришь
Аа. Не, я всё на бэкграунде делаю, даже маппинг Model -> Props
ML
Аа. Не, я всё на бэкграунде делаю, даже маппинг Model -> Props
зочем?
КР
зочем?
Не тратить ресурсы мейн треда? Маппинг может быть достаточно массивным.
ML
Не тратить ресурсы мейн треда? Маппинг может быть достаточно массивным.
ммм, чувствую запах перевентивной оптимизации
ML
в любом случае, если очень хочется ебаться с асинхронщиной – blockingqueue в помощь
КР
ммм, чувствую запах перевентивной оптимизации
Лол. У меня, к примеру, графики есть. В модели хранится общая инфа, с которой нужно работать, а данные непосредственно для вью подготавливаются на бэкграунд треде. Там много вычислений происходит, а сам маппинг выполняется достаточно часто.
КР
ммм, чувствую запах перевентивной оптимизации
Когда litho вытаскивает часть вычислений на бэкграунд - все кричат, что это револшен, Джони. :)
КР
в любом случае, если очень хочется ебаться с асинхронщиной – blockingqueue в помощь
У меня мпп, так что blockingqueue мне не светят.) И даже runBlocking.
VP
У меня мпп, так что blockingqueue мне не светят.) И даже runBlocking.
Тогда Channel, это почти его копия
КР
Тогда Channel, это почти его копия
Я знаю, но там либо опасный offer, либо launch + send, а в таком случае при ддосе сообщениями порядок будет меняться. А делать
dispatch suspend функцией - не вариант.с#
ммм, чувствую запах перевентивной оптимизации
не чувствую запахов