Был Foo, bar, baz , порядок был baz, bar, foo при обходе. Добавили baq, и стало baq, baz, bar, foo

"в лоб" лочить весь мап

тогда пока я буду обходить весь map, а это часы, никто не сможет с ним работать. а это неприемлемо.

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

Чо ты делать будешь?

@MichaelMonashev снапшот

лочишь мап, делаешь копию, отпускаешь. Обходишь копию

или снепшот, или ченджлог :)

тогда пока я буду обходить весь map, а это часы, никто не сможет с ним работать. а это неприемлемо.

Это сколько у тебя там элементов?

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

Лучшее решение. Спасибо!

golang.org/pkg/sync/#Map или вот и Range

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

И ты фактически изобретаешь sync.Map

нет, синкмап устроен иначе

нет, он имел ввижу журнал

но да, возможно, для топикстартера синкмап подойдет лучше

RW мапа изменений которая применяется после длительной операции с основным массивом

повышает эффективность в плане памяти но просаживает цпу

нет, синкмап устроен иначе

Достаточно похоже на то что ты описал на самом деле

Люди подскажите, не могу анмаршал в структуру сделать, где-то накосячил видимо, но байты ловлю. Как то мне прочитать эти байты нуно, посмотреть что внутрях приходит?

а в чем вопрос-то?

посмотрел код https://golang.org/pkg/sync/#Map.Range и не пойму, можно ли в функции, вызываемой для каждого лемента, делать time.Sleep(). . т.е. во время этого слипа другие горутины смогут работать с мэпом или нет?

а в чем вопрос-то?

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

у тебя вопрос "как распечатать байты"?

посмотрел код https://golang.org/pkg/sync/#Map.Range и не пойму, можно ли в функции, вызываемой для каждого лемента, делать time.Sleep(). . т.е. во время этого слипа другие горутины смогут работать с мэпом или нет?

Там делается снэпшот мапы которая для чтения

И по ней итерации идут

И Локи для мержа dirty map с readOnly

у тебя вопрос "как распечатать байты"?

Да, ладно, щас сам поищу.

:)

Так что должно быть нормально.

Функция дёргается не под локом

я тут подумал, что идея со снэпшотом мне не подходит. Хочется при итерации работать всё таки с последними данными map-а.

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

а какого размера мапа-то?

сколько элементов?

около 1 млн.

мне на самом деле подойдёт и получение случайного элемента.

случайный элемент - это вызвать range, получить первый и закрыть цикл

можно еще создать канал с буфером размером с мапу и быстренько затолкать в него ее всю :)

а дальше читай сколько влезет

только при чтении надо еще проверять, все ли еще элемент в мапе

всё таки случайность имелась в виду , что это более мягкий способ обойти ВСЕ элементы.

range гарантировано начинает со случайного места

не знал про такое свойство range. оно прописано в доках или в текущей реализации так?

в доках прописано

в доках прописано

почитал, нету там такого.

да как же нет

The iteration order over maps is not specified and is not guaranteed to be the same from one iteration to the next. If a map entry that has not yet been reached is removed during iteration, the corresponding iteration value will not be produced. If a map entry is created during iteration, that entry may be produced during the iteration or may be skipped. The choice may vary for each entry created and from one iteration to the next. If the map is nil, the number of iterations is 0.

это отсюда: https://golang.org/ref/spec#RangeClause

@MichaelMonashev а зачем вообще тебе нужно такое поведение? И откуда требование "текущего состояния" при range?

скажи лучше - ты помнишь, с какой верси range рандомный гарантировано?

в доки, видимо, это не попало, а было только в release notes

в доки, видимо, это не попало, а было только в release notes

так это тогда поменять могут в любой момент.

могут, но нам-то что?

Дык, станет выбирать всё время, например, один и тот же элемент и не сможет все обойти вообще никогда.

скажи лучше - ты помнишь, с какой верси range рандомный гарантировано?

Я вообще такого не помню.

И у меня чем дальше тем более четкое ощущение что человек хочет какую то херь сделать

И не понимает что ему надо

у меня была похожая задача

И не понимает что ему надо

Я чётко понимаю, что мне надо. Но оно не совпадает с чужими фантазиями.

мапа на миллион, и обход ее. правда, без слипа, но с отсылкой пуша

Я чётко понимаю, что мне надо. Но оно не совпадает с чужими фантазиями.

Ну так может быть стоит описать задачу?

Именно задачу, а не предполагаемое решение

Ну так может быть стоит описать задачу?

Зачем? Чтьобы в очередной раз, как это любят обычно делать для сложных задач, меня назвали мудаком, который всё неправильно делает и хочет неправильного? И вместо того, чтобы подумать над проблемой, думали над моими умственными способностями?

Зачем? Чтьобы в очередной раз, как это любят обычно делать для сложных задач, меня назвали мудаком, который всё неправильно делает и хочет неправильного? И вместо того, чтобы подумать над проблемой, думали над моими умственными способностями?

Так это можно и без описания задачи сделать, не вопрос

Дык, станет выбирать всё время, например, один и тот же элемент и не сможет все обойти вообще никогда.

Можно еще флаг добавить о том, что элемент обработан или время обработки. Чтобы обработанные исключать.

Можно еще флаг добавить о том, что элемент обработан или время обработки. Чтобы обработанные исключать.

А обход как реализовать?

Можно еще флаг добавить о том, что элемент обработан или время обработки. Чтобы обработанные исключать.

Можно при добавлении элементов ещё ключ кидать в канал

ERROR: S client not available

А обход как реализовать?

Так же как и предлагали, рэнж до первого необработанного элемента

А в обходе брать Лок и перебирать из канала элементы пока не будет попадание на живой (если удаление возможно)

Потом читать, снимать Лок и дальше жить

Можно при добавлении элементов ещё ключ кидать в канал

Тоже вариант

Но непонятно что человеку надо

Зачем? Чтьобы в очередной раз, как это любят обычно делать для сложных задач, меня назвали мудаком, который всё неправильно делает и хочет неправильного? И вместо того, чтобы подумать над проблемой, думали над моими умственными способностями?

владимир дело говорит, вообще-то

Но непонятно что человеку надо

Не очень важно) человек хочет понаступать на грабли, чтобы научится. Не будем мешать.

миллион элементов в мапе

майн гот

почему нет-то?

потомучто мноха

не

начинаешь уже думать о редис & etc

много - это в районе 100М где-то

да ты расточитель и пожиратель памяти!

негодяй

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

а почему в качестве решения выбрано посылать один месседж в секунду?

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

Ну тогда точно вариант с каналом и списком ключей на любое изменение

юзеров в редис, клиенты subscribe!

в особо сложных случаях, шину на rabbitMQ

а почему в качестве решения выбрано посылать один месседж в секунду?

Тьфу, удалил. Человек кажется время не говорил нигде. Может там каждые 10мс

я не делаю очередь. Я просто хочу обойти все элементы map-а с паузами в секунду между элементом.

говорил

говорил

Ну так всегда же. Если выглядит так словно человек делает очередь, значит он делает очередь

это да

это только так выглядит

на очердь это не похоже, чесслово

Зачем? Чтьобы в очередной раз, как это любят обычно делать для сложных задач, меня назвали мудаком, который всё неправильно делает и хочет неправильного? И вместо того, чтобы подумать над проблемой, думали над моими умственными способностями?

интересно же

на очердь это не похоже, чесслово

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

очередь это не это)

То что параллельно ему это ещё для чего то нужно - отдельный вопрос

очередь это все-таки список задач