温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

实战Go:HashMap缓存的缓存失效时间动态调整

发布时间:2024-11-08 23:09:34 来源:亿速云 阅读:78 作者:小樊 栏目:编程语言

在Go中,我们可以使用sync.Map作为HashMap缓存。为了实现缓存失效时间的动态调整,我们可以使用一个额外的结构体来存储键、值和过期时间。同时,我们需要一个定时器来定期检查并清除过期的缓存。

以下是一个简单的示例:

package main

import (
	"fmt"
	"sync"
	"time"
)

type CacheItem struct {
	Value      interface{}
	ExpireTime time.Time
}

type DynamicHashMap struct {
	mu          sync.RWMutex
	cache       map[string]CacheItem
	cleanupTicker *time.Ticker
}

func NewDynamicHashMap() *DynamicHashMap {
	return &DynamicHashMap{
		cache:       make(map[string]CacheItem),
		cleanupTicker: time.NewTicker(1 * time.Minute),
	}
}

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

	expireTime := time.Now().Add(ttl)
	dm.cache[key] = CacheItem{
		Value:      value,
		ExpireTime: expireTime,
	}
}

func (dm *DynamicHashMap) Get(key string) (interface{}, bool) {
	dm.mu.RLock()
	defer dm.mu.RUnlock()

	item, ok := dm.cache[key]
	if !ok || time.Now().After(item.ExpireTime) {
		return nil, false
	}

	return item.Value, true
}

func (dm *DynamicHashMap) StartCleanup() {
	go func() {
		for range dm.cleanupTicker.C {
			dm.mu.Lock()
			now := time.Now()
			for key, item := range dm.cache {
				if now.After(item.ExpireTime) {
					delete(dm.cache, key)
				}
			}
			dm.mu.Unlock()
		}
	}()
}

func main() {
	dm := NewDynamicHashMap()
	dm.StartCleanup()

	dm.Set("key1", "value1", 5*time.Second)
	dm.Set("key2", "value2", 10*time.Second)

	time.Sleep(2 * time.Second)
	value, ok := dm.Get("key1")
	if ok {
		fmt.Println("key1:", value)
	} else {
		fmt.Println("key1 not found or expired")
	}

	time.Sleep(8 * time.Second)
	value, ok = dm.Get("key1")
	if ok {
		fmt.Println("key1:", value)
	} else {
		fmt.Println("key1 not found or expired")
	}

	time.Sleep(12 * time.Second)
	value, ok = dm.Get("key2")
	if ok {
		fmt.Println("key2:", value)
	} else {
		fmt.Println("key2 not found or expired")
	}
}

在这个示例中,我们创建了一个DynamicHashMap结构体,它包含一个sync.RWMutex用于保护缓存数据,一个map[string]CacheItem用于存储缓存数据,以及一个*time.Ticker用于定期清理过期缓存。

Set方法用于设置缓存项及其过期时间,Get方法用于获取缓存项(如果存在且未过期),StartCleanup方法用于启动一个定时器,定期检查并清除过期缓存。

main函数中,我们创建了一个DynamicHashMap实例,启动了清理定时器,然后设置了两个缓存项。通过观察输出,我们可以看到缓存项在过期后被正确清除。

向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

go
AI