ConcurrentHashMap

Jul 26, 2021

Changes in this version

+ var SHARD_COUNT = 32

+ type ConcurrentMap []*ConcurrentMapShared

+ func New() ConcurrentMap

+ func (m ConcurrentMap) Clear()

+ func (m ConcurrentMap) Count() int

+ func (m ConcurrentMap) Get(key string) (interface{}, bool)

+ func (m ConcurrentMap) GetShard(key string) *ConcurrentMapShared

+ func (m ConcurrentMap) Has(key string) bool

+ func (m ConcurrentMap) IsEmpty() bool

+ func (m ConcurrentMap) Items() map[string]interface{}

+ func (m ConcurrentMap) Iter() <-chan Tuple

+ func (m ConcurrentMap) IterBuffered() <-chan Tuple

+ func (m ConcurrentMap) IterCb(fn IterCb)

+ func (m ConcurrentMap) Keys() []string

+ func (m ConcurrentMap) MSet(data map[string]interface{})

+ func (m ConcurrentMap) MarshalJSON() ([]byte, error)

+ func (m ConcurrentMap) Pop(key string) (v interface{}, exists bool)

+ func (m ConcurrentMap) Remove(key string)

+ func (m ConcurrentMap) RemoveCb(key string, cb RemoveCb) bool

+ func (m ConcurrentMap) Set(key string, value interface{})

+ func (m ConcurrentMap) SetIfAbsent(key string, value interface{}) bool

+ func (m ConcurrentMap) Upsert(key string, value interface{}, cb UpsertCb) (res interface{})

+ type ConcurrentMapShared struct

+ type IterCb func(key string, v interface{})

+ type RemoveCb func(key string, v interface{}, exists bool) bool

+ type Tuple struct

+ Key string

+ Val interface{}

+ type UpsertCb func(exist bool, valueInMap interface{}, newValue interface{}) interface