169 похожих чатов

А то есть, например, если у тебя сначала был выдан

0 потом 5, ты запустил асинхронную операцию над каждым из этих значений, и у тебя может оказаться так, что для 5 эта операция выполнится быстрее, чем для 0, но тебе надо сначала выдать результат той операции, где был 0?

4 ответов

17 просмотров

Точно. И это надо оптимизировать, не ожидая последовательного завершения каждой итерации по отдельности)

Andrey-Nuzhnov Автор вопроса
Shai Hulud
Точно. И это надо оптимизировать, не ожидая послед...

На самом деле в таком случае тебе всё равно придётся ждать, когда, например, выполняется операция на 0 и уже завершена операция на 5, раз тебе надо выдавать результаты именно в той последовательности, в которой они пришли из флоу. Другой, менее приятный пример, когда у тебя прежде всего была выполнена операция над последним элементом флоу. Выдать ты его не сможешь никак до тех пор, пока не выполнятся операции над предыдущими элементами. То есть придётся ждать выполнения всех предыдущих операций. С другой стороны ты можешь как-нибудь организовать контроль, например, когда выполнилась операция над n-ым элементом, и после этого проверять выполнилась ли операция на всеми предыдущими элементами. И если она выполнилась, то выдавать элементы от 1 до n. В этом случае придётся завести буфер.

Andrey-Nuzhnov Автор вопроса
Andrey Nuzhnov
На самом деле в таком случае тебе всё равно придёт...

Самое первое и банальное решение аналогично твоему последнему, только с переносом toList после map. В этом случае ты собираешь флоу и для каждого значения запускаешь корутину в необходимом тебе контексте (параллельно дальше собирая флоу). Затем ждёшь пока все они выполняться. Только когда они все выполняться у тебя уже будет просто List, а не flow)

Andrey-Nuzhnov Автор вопроса
Andrey Nuzhnov
Самое первое и банальное решение аналогично твоему...

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

Похожие вопросы

Обсуждают сегодня

Есть какой-нибудь для Delphi/FPC T*Compression(Decompression)Stream на базе LZ4/Zstd/любой другой быстрый(и хорошо сжимающий) алгоритм А ещё лучше в pure pascal А ещё лучше од...
notme
48
А чем вам питонисты не угодили?😂
.
79
type TObj = object procedure Init; virtual; end; TObj1 = object(TObj) procedure Init; override; end; procedure TObj1.Init; begin inherited; end; procedur...
Alexander 👋
29
Такой вопросец - есть функция function MySuperDuperConcat(const a: array of AnsiString): AnsiString; Как мне в её теле сделать вот так? Result:=Concat(a); А не грустный вариан...
notme
15
Всем привет. Поделитесь, пожалуйста, опытом. Есть форма, на которой имеется dbgrid и кнопки: добавить, редактировать, удалить. Если нет записей в dbgrid, то кнопки редактирова...
Евгений
5
type TExtensions<GExtender>=class function GetExtension<GEntityExtenderType>:GEntityExtenderType; end; function TExtensions<GExtender>.GetExtension<GEntityExtenderType...
zamtmn
8
Всем привет, написал код ниже, но он выдает сегфолт, в чем причина? #include <stdio.h> #include <stdlib.h> #include <string.h> struct product { char *name; float price; };...
buzz базз
86
Всем привет, препод задал вопрос, подскажите пожалуйста, какой адрес инкапсулирует указатель?
Свинка Пеппа
8
Почему никто ещё не написал квантовую виртуальную машину на Windows?
КТ315
7
Вот смотрите у меня есть два стрима сейчас fs, cs: TStream; fs := TFileStream.Create('filename'); cs := TCompressionStream.Create(compression_level, fs); Я хочу сделать так: ...
notme
5
Карта сайта