Можно ли блокировать 1 ключ вместо всей карты?

Question

[Владимир Грабко]

У меня есть мап (пара миллионов ключей, постоянные обращения). Также там есть подобие сборщика мусора который проверяет время последнего использования ключа и если он стор то удаляет. После этих манипуляций запускается перерасчёт данных в этом мапе (обычный цикл). Это дело раз в 5 секунд 1 секунду не доступно (а это очень плохо). Сейчас думаю как-то сделать блокировку не всего мапа, а 1 ключа. Только вот как это уже не гуглится чёт.

Comments

[Никита]

Быстрее и удобнее использовать Redis.

[Владимир Грабко]

Никита: я уже так и сделал.

[Никита]

Владимир Грабко: вы когда делаете сборку мусора, то закрываете map мьютексом и давай циклом проходить по всему?
Не думали поменять реализацию? Например закрывать map RMutex и создавать дополнительный массив expired ключей, по которым 1 раз быстро удалять ненужные элементы главного map.

Answer 1

[evnuh]

У меня чувство дежавю на этот вопрос. и не зря, я тебе уже отвечал на него:
Потокобезопасность и указатели. Нужны блокировки?

И ещё, на русском не говорят "карта" применительно к структуре данных map.

Ты задал уже больше 100 вопросов, ответ на 95% из них гуглится не дольше пяти секунд. Может быть ты гуглишь на русском, а не на английском, раз у тебя всё время "Только вот как это уже не гуглится чёт."

Comments

[Никита]

+1

Answer 2

[Александр Павлюк]

Со стандартной мапой такое не прокатит. Подумайте над другой организацией данных.

Answer 3

[uvelichitel]

Варианты:
1. Защищать value в map.

type MyMap map{Key]*Value
type Value struct{
sync.RWMutex
value
}

-- пара миллионов замков и добавлять/удалять записи небезогасно
2. Из функционального мира, перерасчитывать данные в новую мапу, потом подменять.
-- большая нагрузка на GarbageCollector.
3. Для вашего частного случая можно еще sync.atomic

type M map[Key]*unsafe.Pointer
type Value *YorValueType
var old, changed Value
m := make(M)
v := unsafe.Pointer(old)
m[key] = &v
old  =  (*Value)(*m[key])
changed := DoSomething(*old)
atomic.StorePointer(m["foo"], unsafe.Pointer(&changed)) //Здесь атомарно подменяется ссылка

-- много редиректов и добавлять/удалять записи небезогасно
4. Разбить мапу на куски []map[Key]Value или

map[Key1]struct{
    sync.RWMutex
    map[key2]Value
    }

блокировать только необходимые куски.
-- многоуровневый доступ, куски все равно нужно блокировать, добавлять/удалять записи небезогасно