mirror of
https://gitee.com/johng/gf.git
synced 2024-12-02 20:28:17 +08:00
109 lines
2.7 KiB
Go
109 lines
2.7 KiB
Go
// Copyright 2018 gf Author(https://github.com/gogf/gf). All Rights Reserved.
|
|
//
|
|
// This Source Code Form is subject to the terms of the MIT License.
|
|
// If a copy of the MIT was not distributed with this file,
|
|
// You can obtain one at https://github.com/gogf/gf.
|
|
|
|
package gcache
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/gogf/gf/container/glist"
|
|
"github.com/gogf/gf/container/gmap"
|
|
"github.com/gogf/gf/container/gtype"
|
|
"github.com/gogf/gf/os/gtimer"
|
|
)
|
|
|
|
// LRU cache object.
|
|
// It uses list.List from stdlib for its underlying doubly linked list.
|
|
type memCacheLru struct {
|
|
cache *memCache // Parent cache object.
|
|
data *gmap.Map // Key mapping to the item of the list.
|
|
list *glist.List // Key list.
|
|
rawList *glist.List // History for key adding.
|
|
closed *gtype.Bool // Closed or not.
|
|
}
|
|
|
|
// newMemCacheLru creates and returns a new LRU object.
|
|
func newMemCacheLru(cache *memCache) *memCacheLru {
|
|
lru := &memCacheLru{
|
|
cache: cache,
|
|
data: gmap.New(true),
|
|
list: glist.New(true),
|
|
rawList: glist.New(true),
|
|
closed: gtype.NewBool(),
|
|
}
|
|
gtimer.AddSingleton(time.Second, lru.SyncAndClear)
|
|
return lru
|
|
}
|
|
|
|
// Close closes the LRU object.
|
|
func (lru *memCacheLru) Close() {
|
|
lru.closed.Set(true)
|
|
}
|
|
|
|
// Remove deletes the <key> FROM <lru>.
|
|
func (lru *memCacheLru) Remove(key interface{}) {
|
|
if v := lru.data.Get(key); v != nil {
|
|
lru.data.Remove(key)
|
|
lru.list.Remove(v.(*glist.Element))
|
|
}
|
|
}
|
|
|
|
// Size returns the size of <lru>.
|
|
func (lru *memCacheLru) Size() int {
|
|
return lru.data.Size()
|
|
}
|
|
|
|
// Push pushes <key> to the tail of <lru>.
|
|
func (lru *memCacheLru) Push(key interface{}) {
|
|
lru.rawList.PushBack(key)
|
|
}
|
|
|
|
// Pop deletes and returns the key from tail of <lru>.
|
|
func (lru *memCacheLru) Pop() interface{} {
|
|
if v := lru.list.PopBack(); v != nil {
|
|
lru.data.Remove(v)
|
|
return v
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Print is used for test only.
|
|
//func (lru *memCacheLru) Print() {
|
|
// for _, v := range lru.list.FrontAll() {
|
|
// fmt.Printf("%v ", v)
|
|
// }
|
|
// fmt.Println()
|
|
//}
|
|
|
|
// SyncAndClear synchronizes the keys from <rawList> to <list> and <data>
|
|
// using Least Recently Used algorithm.
|
|
func (lru *memCacheLru) SyncAndClear() {
|
|
if lru.closed.Val() {
|
|
gtimer.Exit()
|
|
return
|
|
}
|
|
// Data synchronization.
|
|
for {
|
|
if v := lru.rawList.PopFront(); v != nil {
|
|
// Deleting the key from list.
|
|
if v := lru.data.Get(v); v != nil {
|
|
lru.list.Remove(v.(*glist.Element))
|
|
}
|
|
// Pushing key to the head of the list
|
|
// and setting its list item to hash table for quick indexing.
|
|
lru.data.Set(v, lru.list.PushFront(v))
|
|
} else {
|
|
break
|
|
}
|
|
}
|
|
// Data cleaning up.
|
|
for i := lru.Size() - lru.cache.cap; i > 0; i-- {
|
|
if s := lru.Pop(); s != nil {
|
|
lru.cache.clearByKey(s, true)
|
|
}
|
|
}
|
|
}
|