AH
причем ломает катастрофическим образом с подтеками памяти и стопором системы
Size: a a a
2021 January 21
IC
причем ломает катастрофическим образом с подтеками памяти и стопором системы
потому что он делает именно то. что ты просишь
IC
говоршь ему - ебаш в кашу, он и занимается работой
IC
это же всё таки не декларативный язык
VS
Почему гопак не ломается тогда?
IC
Почему гопак не ломается тогда?
тред не читай - люби гопак
AH
потому что он делает именно то. что ты просишь
ну не совсем. тут видна разница в подходах между холодными и горячими процессами.
Если в горячих (тасках) много продьюсеров будут наваливать столько пока память не кончится и им похуй что там консумер не вытягивает,
то в холодных пул стримах (гопак), даже миллиард продьюсеров просто не будут работать пока их из даунстрима не попросят
Если в горячих (тасках) много продьюсеров будут наваливать столько пока память не кончится и им похуй что там консумер не вытягивает,
то в холодных пул стримах (гопак), даже миллиард продьюсеров просто не будут работать пока их из даунстрима не попросят
AH
в тасках над ченелами надо лепить руками бекпрешр чтобы оно не ломалось на высоком параллелизме
IC
ну не совсем. тут видна разница в подходах между холодными и горячими процессами.
Если в горячих (тасках) много продьюсеров будут наваливать столько пока память не кончится и им похуй что там консумер не вытягивает,
то в холодных пул стримах (гопак), даже миллиард продьюсеров просто не будут работать пока их из даунстрима не попросят
Если в горячих (тасках) много продьюсеров будут наваливать столько пока память не кончится и им похуй что там консумер не вытягивает,
то в холодных пул стримах (гопак), даже миллиард продьюсеров просто не будут работать пока их из даунстрима не попросят
я тебе уже 4 раза написал попробовать заменить unbound stream
IC
но в целом я с тобой согласен
AH
я тебе уже 4 раза написал попробовать заменить unbound stream
да я ниибу что ты хочешь поменять) ты можешь код скинуть?
IC
гопак лучше менеджит
IC
да я ниибу что ты хочешь поменять) ты можешь код скинуть?
var entriesChannel = Channel.CreateUnbounded<(string cluster, DateTime start, string[] logs)>(new UnboundedChannelOptions { SingleReader = true }); вот эту строку замени на var entriesChannel = Channel.CreateBounded<(string cluster, DateTime start, string[] logs)>(new BoundedChannelOptions(1000000) { SingleReader = true });AH
а точно сингл ридер?
AH
ну ладно
IC
а точно сингл ридер?
ну ты же пишешь в 1 поток в файл
IC
наверное только лимит надо уменишить до 1000
IC
а не до ляма
AH
а, ну да, ну да
VS
Аяяяй