AH
последний форЫч просто для енумераблей
Size: a a a
2021 January 20
AH
он не параллельный. Там для параллел квери другой есть
AH
ой, даже он не исполняется, что логично :D
AH
он же все еще не закончился. Значит надо костыльнуть параллельным форЫчем с уровнем параллелизма 1
AH
.WithDegreeOfParallelism(1)
.ForAll(x =>
{
var (cluster, start, logs) = x;
afterTask(cluster, start, logs).GetAwaiter().GetResult();
});
.ForAll(x =>
{
var (cluster, start, logs) = x;
afterTask(cluster, start, logs).GetAwaiter().GetResult();
});
AH
DegreeOfParallelism operator may be used at most once in a query
AH
ага, щаз
AH
ну, где два блока, там еще и один лок -_-
AH
поразительные для такого говнокода 140к рпс на моем бенче, но памяти оно отожрало 20гб ни с хуя
AH
надо более честный бенч сделать чтобы можно было оффлайн его проводить
IC
поразительные для такого говнокода 140к рпс на моем бенче, но памяти оно отожрало 20гб ни с хуя
Я тут начал ковырять трилл...
AH
Я тут начал ковырять трилл...
НУ КА ДЕЛИСЬ
AH
впечатления?
IC
Судя по всему, в пайп трила нельзя вставить асинхронные операции
AH
Судя по всему, в пайп трила нельзя вставить асинхронные операции
я не верю что все настолько плохо
AH
это убивает смысл стримов примерно на 100%
AH
т.к. цпу операции никто стримами не делает
IC
То есть надо преобразовать в observable там через рх заинжектить, и потом обратно в istreamable
AH
То есть надо преобразовать в observable там через рх заинжектить, и потом обратно в istreamable
вот да.
AH
я так и пытался. и сдался