Go HashMap缓存的缓存数据过期通知与回调

在Go中，我们可以使用第三方库来实现HashMap缓存，例如go-cache。这个库提供了一个简单的缓存实现，支持设置过期时间和回调函数。以下是一个使用go-cache库实现的示例：

首先，安装go-cache库：

go get github.com/patrickmn/go-cache

然后，创建一个简单的程序，使用go-cache库实现缓存数据的过期通知和回调：

package main

import (
	"fmt"
	"github.com/patrickmn/go-cache"
	"time"
)

// CacheItem 是缓存项的结构体
type CacheItem struct {
	Key       string
	Value     interface{}
	ExpireAt  int64
}

// CacheNotify 是一个回调接口，用于通知缓存项已过期
type CacheNotify interface {
	OnExpired(key string)
}

// MyCacheNotify 是一个实现了CacheNotify接口的结构体
type MyCacheNotify struct{}

// OnExpired 实现了CacheNotify接口的OnExpired方法
func (m *MyCacheNotify) OnExpired(key string) {
	fmt.Printf("Cache item with key '%s' has expired\n", key)
}

func main() {
	// 创建一个新的缓存实例
	c := cache.New(5*time.Minute, 10*time.Minute)

	// 创建一个缓存通知实例
	notify := &MyCacheNotify{}

	// 添加一个缓存项，并设置过期时间为10秒
	c.Set("key1", "value1", 10*time.Second)

	// 启动一个goroutine，定期检查缓存项是否过期
	go func() {
		for {
			now := time.Now().Unix()
			c.mu.Lock()
			for k, v := range c.items {
				if v.ExpireAt < now {
					delete(c.items, k)
					if notify != nil {
						notify.OnExpired(k)
					}
				}
			}
			c.mu.Unlock()
			time.Sleep(1 * time.Second)
		}
	}()

	// 等待缓存项过期
	time.Sleep(15 * time.Second)

	// 再次尝试获取缓存项，将返回nil，因为缓存项已过期
	fmt.Printf("Value for key 'key1': %v\n", c.Get("key1"))
}

在这个示例中，我们创建了一个go-cache缓存实例，并设置了一个缓存项，过期时间为10秒。我们还定义了一个CacheNotify接口和一个实现了该接口的MyCacheNotify结构体。当缓存项过期时，OnExpired方法将被调用。

为了检查缓存项是否过期，我们在一个单独的goroutine中定期遍历缓存项，并删除过期的缓存项。如果缓存项已过期，我们还会调用MyCacheNotify的OnExpired方法来通知缓存项已过期。