實(shí)戰(zhàn)Go：HashMap緩存的緩存失效時(shí)間動(dòng)態(tài)調(diào)整

在Go中，我們可以使用sync.Map作為HashMap緩存。為了實(shí)現(xiàn)緩存失效時(shí)間的動(dòng)態(tài)調(diào)整，我們可以使用一個(gè)額外的結(jié)構(gòu)體來(lái)存儲(chǔ)鍵、值和過(guò)期時(shí)間。同時(shí)，我們需要一個(gè)定時(shí)器來(lái)定期檢查并清除過(guò)期的緩存。

以下是一個(gè)簡(jiǎn)單的示例：

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")
	}
}

在這個(gè)示例中，我們創(chuàng)建了一個(gè)DynamicHashMap結(jié)構(gòu)體，它包含一個(gè)sync.RWMutex用于保護(hù)緩存數(shù)據(jù)，一個(gè)map[string]CacheItem用于存儲(chǔ)緩存數(shù)據(jù)，以及一個(gè)*time.Ticker用于定期清理過(guò)期緩存。

Set方法用于設(shè)置緩存項(xiàng)及其過(guò)期時(shí)間，Get方法用于獲取緩存項(xiàng)（如果存在且未過(guò)期），StartCleanup方法用于啟動(dòng)一個(gè)定時(shí)器，定期檢查并清除過(guò)期緩存。

在main函數(shù)中，我們創(chuàng)建了一個(gè)DynamicHashMap實(shí)例，啟動(dòng)了清理定時(shí)器，然后設(shè)置了兩個(gè)緩存項(xiàng)。通過(guò)觀察輸出，我們可以看到緩存項(xiàng)在過(guò)期后被正確清除。