XL
мердж объединяет N-потоков и выбрасывает все значения, в том порядке, в котором пришли
Size: a a a
2021 March 26
AM
Понял
AM
Тип если 60(1) это поход в сеть, а 1 (2) запись в бд, и 1(2) выполнится быстрее, то данные прийдут в последовательности 60 - 1 ...
AM
?
AM
Крч, трабла в том, что комплитабле как-то не оч в обсервабле конвертируется, сделал что-то похожее на чисто обсервабле, и все приходит
XL
Данные должны пойти в той последовательности, как их выкинули разные потоки
Если 60(1) придет быстрее, чем 1(2), то будет 60 - 1
если 1(2) - придет быстрее, то будет 1 - 60
Если 60(1) придет быстрее, чем 1(2), то будет 60 - 1
если 1(2) - придет быстрее, то будет 1 - 60
AM
Тогда может вместо io, их запускать в потоках neeThreed?
AM
Может быть что в io, они в последовательности зависают
AM
Ну конечно
AM
Так и есть
AM
Хех
XL
👍
AM
Спасибо)
AM
Все стало на свои места все работает 🌝
AM
Мдэ, долгий это процесс, познания дзена рх
AM
какое будет поведение при создании newThreed. в то время как девайс имеет 2 ядра - 2 потока?
AM
он будет их делать в очередь как-то
AM
или как это выглядит
AM
есть виртуальные потоки, имеет ли это отношение к newThread?
P
Artem Mi
какое будет поведение при создании newThreed. в то время как девайс имеет 2 ядра - 2 потока?
сделай просто сэмпл и запусти 10 таких и выведи в логи
изи же, точнее никто не ответит
изи же, точнее никто не ответит