Телеграмм чат группы pro

Говнина какая

14:55пожаловаться #1

Что же произойдет, когда буфер заполнится?

14:55пожаловаться #2

Vasily Shapenko

Что же произойдет, когда буфер заполнится?

надеюсь он не будет в него писать и встанет?

14:56пожаловаться #3

надеюсь он не будет в него писать и встанет?

Ну там скорее будет дискард

14:56пожаловаться #4

ну то есть продьюсер встанет в ожидании

14:56пожаловаться #5

КАк я знаю

14:56пожаловаться #6

Vasily Shapenko

Ну там скорее будет дискард

да ладна

14:56пожаловаться #7

ДА ЛАДНА

14:56пожаловаться #8

(я хз, надо проверить)

14:56пожаловаться #9

НУ ВОТ ТАК

14:56пожаловаться #10

Ilya Chernoudov

 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 });

стало гораздо лучше! половина цпу, 2-3гб, 900к рпс
вроде стабильно

14:57пожаловаться #11

ну то есть продьюсер встанет в ожидании

встанет в await workItemsChannel.Writer.WriteAsync(new WorkItem(i.Item3, i.Item4, i.Item1, i.Item2));

14:57пожаловаться #12

но я поставил там капасити 10

14:57пожаловаться #13

но я поставил там капасити 10

чот мало

14:57пожаловаться #14

Ilya Chernoudov

чот мало

ну так половина цпу.

14:58пожаловаться #15

ну так половина цпу.

ты про капасити ченела?

14:58пожаловаться #16

Ilya Chernoudov

ты про капасити ченела?

я поставил 10 капасити ченела, да

14:58пожаловаться #17

я не думаю что там больше 10 имеет смысл вообще

14:58пожаловаться #18

я поставил 10 капасити ченела, да

а почему половина цпу?

14:59пожаловаться #19

я бы поставил 50 хотябы