溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

高效Go緩存:HashMap與緩存數(shù)據(jù)分片

發(fā)布時(shí)間:2024-11-08 23:27:33 來源:億速云 閱讀:78 作者:小樊 欄目:編程語言

在Go語言中,實(shí)現(xiàn)高效的緩存系統(tǒng)可以使用HashMap和緩存數(shù)據(jù)分片的方法。以下是一個(gè)示例代碼,展示了如何使用這兩種技術(shù)來構(gòu)建一個(gè)高效的緩存系統(tǒng):

package main

import (
	"fmt"
	"sync"
)

// CacheItem 是緩存項(xiàng)的結(jié)構(gòu)體
type CacheItem struct {
	key   string
	value interface{}
	expire int64 // 過期時(shí)間戳
}

// LRUCache 是基于HashMap和緩存數(shù)據(jù)分片的LRU緩存實(shí)現(xiàn)
type LRUCache struct {
	capacity int           // 緩存容量
	cache    map[string]*CacheItem // HashMap存儲(chǔ)緩存項(xiàng)
	evictList *list.List      // 雙向鏈表用于維護(hù)訪問順序
	mu        sync.Mutex     // 互斥鎖用于保護(hù)共享資源
}

// NewLRUCache 創(chuàng)建一個(gè)新的LRU緩存實(shí)例
func NewLRUCache(capacity int) *LRUCache {
	return &LRUCache{
		capacity: capacity,
		cache:    make(map[string]*CacheItem),
		evictList: list.New(),
	}
}

// Get 獲取緩存項(xiàng),如果不存在則返回nil
func (c *LRUCache) Get(key string) interface{} {
	c.mu.Lock()
	defer c.mu.Unlock()

	item, ok := c.cache[key]
	if !ok || item.expire < time.Now().UnixNano() {
		return nil
	}

	// 將訪問的緩存項(xiàng)移動(dòng)到鏈表頭部
	c.evictList.MoveToFront(item)
	return item.value
}

// Put 將緩存項(xiàng)放入緩存,如果超出容量則移除最近最少使用的緩存項(xiàng)
func (c *LRUCache) Put(key string, value interface{}, ttl int64) {
	c.mu.Lock()
	defer c.mu.Unlock()

	if item, ok := c.cache[key]; ok {
		// 更新緩存項(xiàng)的值和過期時(shí)間
		item.value = value
		item.expire = time.Now().UnixNano() + ttl
		c.evictList.MoveToFront(item)
	} else {
		// 如果緩存已滿,移除最近最少使用的緩存項(xiàng)
		if c.evictList.Len() >= c.capacity {
			last := c.evictList.Back()
			delete(c.cache, last.Value.(*CacheItem).key)
			c.evictList.Remove(last)
		}

		// 添加新的緩存項(xiàng)
		item := &CacheItem{
			key:   key,
			value: value,
			expire: time.Now().UnixNano() + ttl,
		}
		c.cache[key] = item
		c.evictList.PushFront(item)
	}
}

func main() {
	cache := NewLRUCache(3)
	cache.Put("key1", "value1", 10)
	cache.Put("key2", "value2", 20)
	cache.Put("key3", "value3", 30)

	fmt.Println(cache.Get("key1")) // 輸出: value1
	cache.Put("key4", "value4", 40)   // 移除key2
	fmt.Println(cache.Get("key2")) // 輸出: nil
	fmt.Println(cache.Get("key3")) // 輸出: value3
	fmt.Println(cache.Get("key4")) // 輸出: value4
}

在這個(gè)示例中,我們定義了一個(gè)LRUCache結(jié)構(gòu)體,它包含一個(gè)HashMap用于存儲(chǔ)緩存項(xiàng),一個(gè)雙向鏈表用于維護(hù)訪問順序,以及一個(gè)互斥鎖用于保護(hù)共享資源。LRUCache提供了GetPut方法,分別用于獲取緩存項(xiàng)和添加緩存項(xiàng)。當(dāng)緩存已滿時(shí),Put方法會(huì)移除最近最少使用的緩存項(xiàng)。

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

go
AI