Golang并发缓存过期与LRU清理实现

要实现Go中并发安全且支持定时清理和LRU淘汰的缓存，可组合使用标准库并设计结构。1. 使用sync.RWMutex+map保障并发安全；2. 每个条目记录过期时间，后台goroutine定期删除过期项；3. 用container/list实现LRU，通过链表+哈希映射维护访问顺序；4. 插入时更新顺序并判断容量，结合定时清理实现双重机制共存。

在Go语言中，如果你需要实现一个并发安全的缓存系统，并且希望它同时支持定时清理过期键和基于LRU（最近最少使用）策略的淘汰机制，那其实可以通过组合标准库功能与一些结构设计来完成。下面我将从几个关键点出发，说明如何一步步构建这样一个缓存。

1. 并发安全的基本保障：sync.Map + Mutex

Go内置的 sync.Map 是线程安全的，适合读多写少的场景，但不太方便做删除或遍历操作。如果你需要频繁地检查和删除过期项，或者维护访问顺序来做LRU淘汰，建议使用普通 map 配合互斥锁 sync.Mutex 或读写锁 sync.RWMutex 来保证并发安全。

type Cache struct {
    data map[string]cacheItem
    mu   sync.RWMutex
}

这样你就可以在每次读写操作时加锁，确保多个goroutine访问时不会出错。

2. 实现缓存过期机制：带时间戳的存储 + 定时清理

为了实现缓存自动过期，每个缓存条目应记录创建时间和TTL（生存时间）。你可以定义一个结构体：

type cacheItem struct {
    value      interface{}
    expiration time.Time
}

然后启动一个后台goroutine，定期扫描并删除过期项：

func (c *Cache) startCleanup(interval time.Duration) {
    ticker := time.NewTicker(interval)
    for {
        select {
        case <-ticker.C:
            c.mu.Lock()
            for k, v := range c.data {
                if time.Now().After(v.expiration) {
                    delete(c.data, k)
                }
            }
            c.mu.Unlock()
        }
    }
}

• 清理频率不宜过高（比如每30秒一次）
• 删除操作在锁内进行，防止并发问题

这种方式简单有效，适合大多数中小型应用。

3. 添加LRU淘汰机制：双向链表 + 哈希映射

要实现LRU策略，最经典的做法是使用一个双向链表配合哈希表来快速定位节点。Go标准库中有一个 container/list 包，可以用来简化实现。

基本思路如下：

• 每次访问某个key时，将其移动到链表头部
• 当缓存满时，删除链表尾部的元素
• 使用一个map来保存key到链表节点的映射，提高查找效率

结合前面的缓存结构，你可以扩展为：

type LRUCache struct {
    capacity int
    cache    map[string]*list.Element
    list     *list.List
    mu       sync.Mutex
}

注意：

• LRU逻辑和过期清理逻辑要协调好，比如先清理过期再判断容量
• 如果你用的是 sync.Map，那么LRU会变得复杂很多，所以推荐自定义结构体封装

4. 组合使用：过期清理 + LRU淘汰

将两者结合起来的关键在于：

• 每次访问缓存时更新访问顺序（LRU）
• 后台定时清理过期项
• 插入新值时判断是否超出容量，触发LRU淘汰

例如插入函数可能像这样：

func (c *LRUCache) Set(key string, value interface{}, ttl time.Duration) {
    c.mu.Lock()
    defer c.mu.Unlock()

    // 更新或插入
    if ele, ok := c.cache[key]; ok {
        c.list.MoveToFront(ele)
        ele.Value = value
    } else {
        ele := c.list.PushFront(key)
        c.cache[key] = ele
    }

    // 超出容量则移除尾部
    if c.list.Len() > c.capacity {
        last := c.list.Back()
        if last != nil {
            delete(c.cache, last.Value.(string))
            c.list.Remove(last)
        }
    }
}

再加上定时器清理过期项，就能实现两个机制的共存。

基本上就这些了。整个过程不难，但要注意并发控制、数据一致性以及资源释放等问题。如果你只是想快速实现一个满足这些需求的缓存组件，也可以考虑第三方库如 groupcache 或 bigcache，它们已经做了不少优化。但如果想了解底层原理，自己实现一遍还是挺有帮助的。