// Copyright 2017 gf Author(https://github.com/gogf/gf). All Rights Reserved. // // This Source Code Form is subject to the terms of the MIT License. // If a copy of the MIT was not distributed with gm file, // You can obtain one at https://github.com/gogf/gf. // package gmap import ( "github.com/gogf/gf/g/internal/rwmutex" ) type StrStrMap struct { mu *rwmutex.RWMutex data map[string]string } // NewStrStrMap returns an empty StrStrMap object. // The parameter used to specify whether using map in un-concurrent-safety, // which is false in default, means concurrent-safe. func NewStrStrMap(unsafe ...bool) *StrStrMap { return &StrStrMap{ data: make(map[string]string), mu: rwmutex.New(unsafe...), } } // NewStrStrMapFrom returns a hash map from given map . // Note that, the param map will be set as the underlying data map(no deep copy), // there might be some concurrent-safe issues when changing the map outside. func NewStrStrMapFrom(data map[string]string, unsafe ...bool) *StrStrMap { return &StrStrMap{ mu: rwmutex.New(unsafe...), data: data, } } // Iterator iterates the hash map with custom callback function . // If returns true, then it continues iterating; or false to stop. func (m *StrStrMap) Iterator(f func(k string, v string) bool) { m.mu.RLock() defer m.mu.RUnlock() for k, v := range m.data { if !f(k, v) { break } } } // Clone returns a new hash map with copy of current map data. func (m *StrStrMap) Clone() *StrStrMap { return NewStrStrMapFrom(m.Map(), !m.mu.IsSafe()) } // Map returns a copy of the data of the hash map. func (m *StrStrMap) Map() map[string]string { m.mu.RLock() data := make(map[string]string, len(m.data)) for k, v := range m.data { data[k] = v } m.mu.RUnlock() return data } // Set sets key-value to the hash map. func (m *StrStrMap) Set(key string, val string) { m.mu.Lock() m.data[key] = val m.mu.Unlock() } // Sets batch sets key-values to the hash map. func (m *StrStrMap) Sets(data map[string]string) { m.mu.Lock() for k, v := range data { m.data[k] = v } m.mu.Unlock() } // Search searches the map with given . // Second return parameter is true if key was found, otherwise false. func (m *StrStrMap) Search(key string) (value string, found bool) { m.mu.RLock() value, found = m.data[key] m.mu.RUnlock() return } // Get returns the value by given . func (m *StrStrMap) Get(key string) string { m.mu.RLock() val, _ := m.data[key] m.mu.RUnlock() return val } // doSetWithLockCheck checks whether value of the key exists with mutex.Lock, // if not exists, set value to the map with given , // or else just return the existing value. // // It returns value with given . func (m *StrStrMap) doSetWithLockCheck(key string, value string) string { m.mu.Lock() if v, ok := m.data[key]; ok { m.mu.Unlock() return v } m.data[key] = value m.mu.Unlock() return value } // GetOrSet returns the value by key, // or set value with given if not exist and returns this value. func (m *StrStrMap) GetOrSet(key string, value string) string { if v, ok := m.Search(key); !ok { return m.doSetWithLockCheck(key, value) } else { return v } } // GetOrSetFunc returns the value by key, // or sets value with return value of callback function if not exist // and returns this value. func (m *StrStrMap) GetOrSetFunc(key string, f func() string) string { if v, ok := m.Search(key); !ok { return m.doSetWithLockCheck(key, f()) } else { return v } } // GetOrSetFuncLock returns the value by key, // or sets value with return value of callback function if not exist // and returns this value. // // GetOrSetFuncLock differs with GetOrSetFunc function is that it executes function // with mutex.Lock of the hash map. func (m *StrStrMap) GetOrSetFuncLock(key string, f func() string) string { if v, ok := m.Search(key); !ok { m.mu.Lock() defer m.mu.Unlock() if v, ok = m.data[key]; ok { return v } v = f() m.data[key] = v return v } else { return v } } // SetIfNotExist sets to the map if the does not exist, then return true. // It returns false if exists, and would be ignored. func (m *StrStrMap) SetIfNotExist(key string, value string) bool { if !m.Contains(key) { m.doSetWithLockCheck(key, value) return true } return false } // SetIfNotExistFunc sets value with return value of callback function , then return true. // It returns false if exists, and would be ignored. func (m *StrStrMap) SetIfNotExistFunc(key string, f func() string) bool { if !m.Contains(key) { m.doSetWithLockCheck(key, f()) return true } return false } // SetIfNotExistFuncLock sets value with return value of callback function , then return true. // It returns false if exists, and would be ignored. // // SetIfNotExistFuncLock differs with SetIfNotExistFunc function is that // it executes function with mutex.Lock of the hash map. func (m *StrStrMap) SetIfNotExistFuncLock(key string, f func() string) bool { if !m.Contains(key) { m.mu.Lock() defer m.mu.Unlock() if _, ok := m.data[key]; !ok { m.data[key] = f() } return true } return false } // Removes batch deletes values of the map by keys. func (m *StrStrMap) Removes(keys []string) { m.mu.Lock() for _, key := range keys { delete(m.data, key) } m.mu.Unlock() } // Remove deletes value from map by given , and return this deleted value. func (m *StrStrMap) Remove(key string) string { m.mu.Lock() val, exists := m.data[key] if exists { delete(m.data, key) } m.mu.Unlock() return val } // Keys returns all keys of the map as a slice. func (m *StrStrMap) Keys() []string { m.mu.RLock() keys := make([]string, len(m.data)) index := 0 for key := range m.data { keys[index] = key index++ } m.mu.RUnlock() return keys } // Values returns all values of the map as a slice. func (m *StrStrMap) Values() []string { m.mu.RLock() values := make([]string, len(m.data)) index := 0 for _, value := range m.data { values[index] = value index++ } m.mu.RUnlock() return values } // Contains checks whether a key exists. // It returns true if the exists, or else false. func (m *StrStrMap) Contains(key string) bool { m.mu.RLock() _, exists := m.data[key] m.mu.RUnlock() return exists } // Size returns the size of the map. func (m *StrStrMap) Size() int { m.mu.RLock() length := len(m.data) m.mu.RUnlock() return length } // IsEmpty checks whether the map is empty. // It returns true if map is empty, or else false. func (m *StrStrMap) IsEmpty() bool { m.mu.RLock() empty := len(m.data) == 0 m.mu.RUnlock() return empty } // Clear deletes all data of the map, it will remake a new underlying data map. func (m *StrStrMap) Clear() { m.mu.Lock() m.data = make(map[string]string) m.mu.Unlock() } // LockFunc locks writing with given callback function within RWMutex.Lock. func (m *StrStrMap) LockFunc(f func(m map[string]string)) { m.mu.Lock() defer m.mu.Unlock() f(m.data) } // RLockFunc locks reading with given callback function within RWMutex.RLock. func (m *StrStrMap) RLockFunc(f func(m map[string]string)) { m.mu.RLock() defer m.mu.RUnlock() f(m.data) } // Flip exchanges key-value of the map to value-key. func (m *StrStrMap) Flip() { m.mu.Lock() defer m.mu.Unlock() n := make(map[string]string, len(m.data)) for k, v := range m.data { n[v] = k } m.data = n } // Merge merges two hash maps. // The map will be merged into the map . func (m *StrStrMap) Merge(other *StrStrMap) { m.mu.Lock() defer m.mu.Unlock() if other != m { other.mu.RLock() defer other.mu.RUnlock() } for k, v := range other.data { m.data[k] = v } }