типа того https://play.golang.org/p/4Uyv0EPqpf

типа того https://play.golang.org/p/4Uyv0EPqpf

https://play.golang.org/p/9TI4v1xLOc

Ты мне ответил моим же примером, тебе надо новую ссылку сделать :)

ну лан

товарищи, а кто-нибудь работал с чтением из Kafka? Sarama использовали, небось?

интересует вот эта штука, в частности. Ибо нужны consumer groups https://godoc.org/github.com/bsm/sarama-cluster

Еще вопрос: Канал созданный следующим объявлением "var chan int" имеет емкость 0, 1, множество?

Короче ответ: 0

я, честно, пока еще не вкурил в фишку, зачем нужны буферизованные каналы

без них должно и так все работать

я тож их еще ниразу не применял

без них должно и так все работать

С их помощью можно например мьютекс эмулировать, но это такое, неудачный пример :)

С их помощью можно например мьютекс эмулировать, но это такое, неудачный пример :)

внезапно каналы внутри устроены через мьютекс

эмулировать мьютекс через мьютекс?..

эмулировать мьютекс через мьютекс?..

Ехал мьютекс через мьютекс

Я же сказал, что неудачный пример :)

вы мне про кафку расскажете или нет? неужто никто с ней не работал?

эмулировать мьютекс через мьютекс?..

Их там не один

я, честно, пока еще не вкурил в фишку, зачем нужны буферизованные каналы

затем чтобы параллельно кусок буфера раскидывать на другие горотины. например в несколько процессов задачу решать

Их там не один

да, но это неважно. пытаться эмулировать мьютексы с помощью мьютексов - это, мм, пахнет тяжело действующими веществами.

затем чтобы параллельно кусок буфера раскидывать на другие горотины. например в несколько процессов задачу решать

в каком смысле параллельно? чтение из канала все равно последовательное же

разве нет?

ну он считает по размеру буфера

и можно со считанным работать параллельно

:)

я, честно, пока еще не вкурил в фишку, зачем нужны буферизованные каналы

Одна горутина может читать из канала и отправлять пачкой данные куда-то. А за это время ей другие горутины ещё накидают пачку. Ну, например.

в каком смысле параллельно? чтение из канала все равно последовательное же

затем что блокировки на чтении не наступает пока буфер

запулил 3 значения - запустил 3 горотины. ждешь пока просрется хоть одна и заново

не надо про пулл сопроцессов думать, например

данные в канале с объемом 10 будут читаться не по очереди, а сразу 10 и будут читаться?

Ну это необязательно параллельно

Это никто не гарантирует

Concurrency is not parallelism, жи

ну вот у меня просто сейчас задача

асинхронно, ок

надо читать из кафки данные как можно быстрее, ибо данных дохрена

неужто добавление буферизации может помочь?

может воркгруппа помочь, вероятно

ну попробуй - нам расскажешь

Еще вопрос из мейловских тестов, что будет в выводе:

func keepCalmAndPanic(msg string) { panic(msg) } func main() { defer func() { if err := recover(); err != nil { fmt.Print(err.(error).Error()) } }() go keepCalmAndPanic("Aargh!") fmt.Printf("It's fine") }

может воркгруппа помочь, вероятно

ээ, это же просто инкрементальный мьютекс

как он поможет?

Concurrency is not parallelism, жи

Я ж напейсал что сопроцессы

короче выйдет "It's fine"

короче выйдет "It's fine"

не всегда

func keepCalmAndPanic(msg string) { panic(msg) } func main() { defer func() { if err := recover(); err != nil { fmt.Print(err.(error).Error()) } }() go keepCalmAndPanic("Aargh!") fmt.Printf("It's fine") }

не определено же, что первое отработает.

не всегда

там проверка на error - которого нет

там проверка на error - которого нет

Может быстрее горутина с panic отработать

там проверка на error - которого нет

скорее всего, он напечатает итс файн и вывалится со стактрейсом в панику

Может быстрее горутина с panic отработать

this

от машины зависит, в общем

вот ща проверил https://play.golang.org/p/dzoh28cjuU

На плее быстрее выходит, горутина не успевает:) Но вообще, конечно, это правда не определено.

https://play.golang.org/p/x_Aa7TWlLs - если time.Sleep впихнуть

вот ща проверил https://play.golang.org/p/dzoh28cjuU

На плее много поведения детерминировано

как он поможет?

wg.Add(n) for i := 0; i < n; i ++ { go func(wg sync.Waitgroup) { doSomething() wg.Done() }(wg) } wg.Wait()

wg.Add(n) for i := 0; i < n; i ++ { go func(wg sync.Waitgroup) { doSomething() wg.Done() }(wg) } wg.Wait()

я знаю прекрасно, как он работает

я не понимаю, как он поможет быстрее кафку разбирать)

https://certification.mail.ru/tests/golang35/start/

А насколько много данных из неё? Сколько штук в секунду? Проще всего вроде на каждое горутину плодить и не париться в общем случае.

А вы еэти тесты проходили, просто при приеме на работу - у меня их спросили

сейчас прошел ради интереса, а вообще нет

у нас свой опросник

А насколько много данных из неё? Сколько штук в секунду? Проще всего вроде на каждое горутину плодить и не париться в общем случае.

несколько десятков тысяч в секунду, вот в чем дело

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

у нас свой опросник

Посмотреть можно?

кину в личку

несколько десятков тысяч в секунду, вот в чем дело

Тогда я бы поднял горутин по количеству ядер процессора, чтоб снизить до минимума оверхед от них. А буфер нафиг не нужен, да. Одна получает данные, и кидает в канал, где остальные обрабатывают.

Тогда я бы поднял горутин по количеству ядер процессора, чтоб снизить до минимума оверхед от них. А буфер нафиг не нужен, да. Одна получает данные, и кидает в канал, где остальные обрабатывают.

ну вот я так и сделал в целом, только смотрю через консоль - не успевает разгребать, растет лаг

я вот и думал, может, несколько консюмеров стартовать или смысла нет?

ну вот я так и сделал в целом, только смотрю через консоль - не успевает разгребать, растет лаг

А процессор на 100% сожран?

кину в личку

Можно и мне тоже?

:)

кину в личку

И мне:) Да в чат уже кидай.

А процессор на 100% сожран?

я этот код запускаю на тестовом сервере с 52 ядрами. Там реально сложно все сожрать

И мне:) Да в чат уже кидай.

+

да он простенький, обычно новичкам задаем на собесах

ну зато нет двусмысленных вопросов как в мейле

я этот код запускаю на тестовом сервере с 52 ядрами. Там реально сложно все сожрать

надо htop смотреть. Может та, первая, которая получает данные, не успевает разбирать и раздавать. И вообще стоит запрофайлить:)

Например: Каким образом реализован механизм исключений (exception) в Go?

Например: Каким образом реализован механизм исключений (exception) в Go?

это вообще провокационный вопрос

Например: Каким образом реализован механизм исключений (exception) в Go?

хреновым

троллинг ага

Спасибо :)

творение не мое, спасибо автору)

да он простенький, обычно новичкам задаем на собесах

Я на втором засыпался:)

как ни странно, приходит народ на собесы

и спрашивают А что такое iota?

при этом опыт на Go год+

и спрашивают А что такое iota?

Смешно :)

Ну зачем писать-то несколько iota в одном блоке const :(

тесты вообще зло

Я на втором засыпался:)

Я бы на третьем. Расплывчатый вопрос.

Я бы на третьем. Расплывчатый вопрос.

в памяти

Я бы на третьем. Расплывчатый вопрос.

В оперативной памяти, да

какой вопрос - такой ответ

Ну ещё в куче и в стеке

Я бы на третьем. Расплывчатый вопрос.

Это из разряда, что в куче, а что в стеке, наверное