X
Size: a a a
2021 January 19
IC
Я так и не понял как из одного стрима вдесятером читать
А нахуя? У тебя то же самое на гопаке
AH
А нахуя? У тебя то же самое на гопаке
ну нет же
AH
кстати, что это за шрифт?
дефолтный в райдере. наверное моно
IC
40k rps на моем бенче
А сколько должно быть? 70?
AH
А сколько должно быть? 70?
ну хотя бы 400. гопачила 500 давал
AH
но в один поток это нереально.
IC
то есть каждый стрим читал файл от начала до конца
У тебя в коде было то же самое - 10 потоков читали свой сегмент базы
AH
щас я навелосипедю параллелизацию асинкенумов, может взлетит
AH
У тебя в коде было то же самое - 10 потоков читали свой сегмент базы
не, там N воркеров набрасывались на один кластер
IC
не, там N воркеров набрасывались на один кластер
Который бился на сегменты
AH
пока один читает интервал 100мс, другой уже ломился читать следующий
IC
Непересекающиеся
AT
кстати, что это за шрифт?
ставь шрифт fira code, не прогадаешь
NT
а можно вычитывать так, чтобы лобстеров сразу варёными ловили?
можно, но вылавливать их варёными будут недолго
IC
А еще здесь после мержа мы читаем только один стрим, то есть остальным шанса не дают на чтение пока первый из смерженных доступен. никакого fairness
опять же, multiple consumers - недоступная магия. Надо велосипедить
опять же, multiple consumers - недоступная магия. Надо велосипедить
Сделай мерж в channel