代码拉取完成,页面将自动刷新
package g2cache
import (
"github.com/coocood/freecache"
"sync"
)
var (
DefaultFreeCacheSize = 50 * 1024 * 1024 // 50MB
)
type FreeCache struct {
storage *freecache.Cache
stop chan struct{}
stopOnce sync.Once
}
func NewFreeCache() *FreeCache {
f := &FreeCache{
storage: freecache.NewCache(DefaultFreeCacheSize),
stop: make(chan struct{}, 1),
}
return f
}
func (c *FreeCache) Set(key string, e *Entry) error {
select {
case <-c.stop:
return LocalStorageClose
default:
}
s, _ := json.Marshal(e)
// local storage should set Obsolete time
obsolete := e.GetObsoleteTTL()
return c.storage.Set([]byte(key), s, int(obsolete))
}
func (c *FreeCache) Del(key string) error {
select {
case <-c.stop:
return LocalStorageClose
default:
}
c.storage.Del([]byte(key))
return nil
}
func (c *FreeCache) Get(key string, obj interface{}) (*Entry, bool, error) {
select {
case <-c.stop:
return nil, false, LocalStorageClose
default:
}
b, err := c.storage.Get([]byte(key))
if err != nil {
if err == freecache.ErrNotFound {
return nil, false, nil
}
return nil, false, err
}
e := new(Entry)
e.Value = obj // Save the reflection structure of obj
err = json.Unmarshal(b, e)
if err != nil {
return nil, false, err
}
return e, true, nil
}
func (c *FreeCache) close() {
close(c.stop)
c.storage.Clear()
}
func (c *FreeCache) Close() {
c.stopOnce.Do(c.close)
}
func (c *FreeCache) ThreadSafe() {}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。