在Go中,HashMap并不是线程安全的,因此在多线程环境下使用时需要额外的同步措施。Go提供了sync.Map
类型,它是一个线程安全的map实现,但如果你需要更细粒度的锁控制,可以使用sync.RWMutex
来实现。
下面是一个使用sync.RWMutex
实现细粒度锁控制的HashMap示例:
package main
import (
"fmt"
"sync"
)
type FineGrainedHashMap struct {
mu sync.RWMutex
items map[string]interface{}
}
func NewFineGrainedHashMap() *FineGrainedHashMap {
return &FineGrainedHashMap{
items: make(map[string]interface{}),
}
}
func (f *FineGrainedHashMap) Set(key string, value interface{}) {
f.mu.Lock()
defer f.mu.Unlock()
f.items[key] = value
}
func (f *FineGrainedHashMap) Get(key string) (interface{}, bool) {
f.mu.RLock()
defer f.mu.RUnlock()
value, ok := f.items[key]
return value, ok
}
func (f *FineGrainedHashMap) Delete(key string) {
f.mu.Lock()
defer f.mu.Unlock()
delete(f.items, key)
}
func main() {
hashMap := NewFineGrainedHashMap()
// 写入数据
hashMap.Set("key1", "value1")
hashMap.Set("key2", "value2")
// 读取数据
value, ok := hashMap.Get("key1")
if ok {
fmt.Println("key1:", value)
}
// 删除数据
hashMap.Delete("key1")
// 再次读取数据
value, ok = hashMap.Get("key1")
if !ok {
fmt.Println("key1 not found")
}
}
在这个示例中,我们定义了一个FineGrainedHashMap
结构体,它包含一个sync.RWMutex
类型的字段mu
和一个map[string]interface{}
类型的字段items
。我们实现了Set
、Get
和Delete
方法,这些方法分别用于设置、获取和删除map中的数据。在这些方法中,我们使用mu
来保护对items
的访问,以实现细粒度的锁控制。
当多个goroutine同时访问FineGrainedHashMap
时,sync.RWMutex
会根据读写操作的不同自动加锁和解锁,从而实现高效的并发访问。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。