要实现go语言中的并发安全缓存系统，关键在于使用sync.rwmutex和过期策略。1. 使用读写锁（rwmutex）保证并发安全，读操作用rlock，写操作用lock；2. 为缓存项添加过期时间，通过setwithttl设置ttl并用time.now().add计算过期时间戳；3. 获取时判断是否过期，仅返回未过期数据；4. 启动后台goroutine定期调用gconce清理过期项；5. 实际使用中建议合理设置ttl、支持永不过期选项、引入淘汰策略，并注意避免频繁gc、缓存雪崩和锁竞争问题。
在go语言中，实现一个并发安全的缓存系统并不难，关键在于合理使用读写锁和过期策略。如果你的应用需要频繁访问数据，又不想每次都去查数据库或者远程接口，本地缓存是个不错的选择。
下面我们就来看看如何结合sync.RWMutex（读写锁）和简单的过期机制来构建一个线程安全、自动清理的缓存结构。
使用读写锁保证并发安全
Go标准库中的sync.RWMutex是实现并发安全访问共享资源的常用方式。对于缓存来说，通常读操作远多于写操作，所以用读写锁比互斥锁（Mutex）更高效。
立即学习“go语言免费学习笔记（深入）”；
举个例子，当你有一个全局的map作为缓存容器时：
type Cache struct { mu sync.RWMutex data map[string]interface{} }
每次读取的时候加读锁：
func (c *Cache) Get(key string) (interface{}, bool) { c.mu.RLock() defer c.mu.RUnlock() val, ok := c.data[key] return val, ok }
写入或删除的时候加写锁：
func (c *Cache) Set(key string, value interface{}) { c.mu.Lock() defer c.mu.Unlock() c.data[key] = value } func (c *Cache) Delete(key string) { c.mu.Lock() defer c.mu.Unlock() delete(c.data, key) }
这样就能避免多个goroutine同时修改导致的数据竞争问题了。
加入过期时间，自动清理无效数据
只做并发控制还不够，如果缓存一直不清理，内存会越占越多。所以你需要给每个缓存项加上过期时间，并定期检查清理。
可以扩展上面的结构体，为每个值添加一个过期时间戳：
type item struct { value interface{} expireTime time.Time } type Cache struct { mu sync.RWMutex data map[string]item }
设置缓存时传入一个TTL（存活时间）：
func (c *Cache) SetWithTTL(key string, value interface{}, ttl time.Duration) { c.mu.Lock() defer c.mu.Unlock() c.data[key] = item{ value: value, expireTime: time.Now().Add(ttl), } }
获取的时候判断是否过期：
func (c *Cache) Get(key string) (interface{}, bool) { c.mu.RLock() defer c.mu.RUnlock() it, ok := c.data[key] if !ok { return nil, false } if time.Now().After(it.expireTime) { return nil, false } return it.value, true }
至于清理过期项，可以用一个后台goroutine定时扫描：
func (c *Cache) StartGC(interval time.Duration) { go func() { ticker := time.NewTicker(interval) for { <-ticker.C c.GCOnce() } }() } func (c *Cache) GCOnce() { now := time.Now() c.mu.Lock() defer c.mu.Unlock() for k, v := range c.data { if now.After(v.expireTime) { delete(c.data, k) } } }
这样就实现了基本的自动清理逻辑。
实际使用中的一些小建议
- TTL设多少合适？ 要根据业务需求决定，比如用户信息可能设5分钟，热点配置可以设30秒。
- 是否要支持永不过期？ 可以加一个NoExpire的选项，比如传time.Duration(0)表示永不过期。
- 要不要考虑淘汰策略？ 如果缓存容量有限，还可以引入LRU或LFU算法做淘汰。
- 性能问题注意点：
- 频繁GC会影响性能，建议间隔不要太短；
- 大量缓存同时失效可能会造成雪崩，可以加一个随机偏移时间；
- 对于高并发场景，也可以考虑分片缓存，减少锁竞争。
基本上就这些。用好读写锁+过期管理，你就可以在Go里实现一个轻量但实用的并发安全缓存系统了。不复杂但细节容易忽略，慢慢打磨就好。
