p93542168
/
wheat-cache
1
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

feat(lru): update lru clean work

This commit is contained in:
HuangJiaLuo 2021-10-11 19:01:24 +08:00
parent 73e91b3ff0
commit 922fae0f78
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pkg/lru/clean_work.go
View File

@ -3,7 +3,6 @@ package lru
import ( import (
"context" "context"
"gitee.com/timedb/wheatCache/pkg/event" "gitee.com/timedb/wheatCache/pkg/event"
"gitee.com/timedb/wheatCache/pkg/logx"
"time" "time"
) )
@ -22,9 +21,9 @@ func (lru *SingleCache) cleanWork() {
lruCleanEvent.SetValue(WorkFuncEventKey, work) lruCleanEvent.SetValue(WorkFuncEventKey, work)
lru.lruCleanProduce.Call(cxt, lruCleanEvent) lru.lruCleanProduce.Call(cxt, lruCleanEvent)
_, err := lruCleanEvent.StartWaitEvent(20 * time.Minute) //常量 _, err := lruCleanEvent.StartWaitEvent(defaultWaitTime)
if err != nil { if err != nil {
logx.With(cxt, ).Error("cleanWork err: %v", err) //logx.With(cxt, ).Error("cleanWork err: %v", err)
} }
} }

5
pkg/lru/define.go
View File

@ -4,6 +4,7 @@ import (
"gitee.com/timedb/wheatCache/pkg/proto" "gitee.com/timedb/wheatCache/pkg/proto"
"gitee.com/timedb/wheatCache/pkg/structure" "gitee.com/timedb/wheatCache/pkg/structure"
"sync" "sync"
"time"
) )
type SingleWorkFunc func() interface{} type SingleWorkFunc func() interface{}
@ -24,7 +25,9 @@ const (
defaultLruClearSize = 0.5 * 1024 * 1024 * 1024 * 8 defaultLruClearSize = 0.5 * 1024 * 1024 * 1024 * 8
defaultLruEventDriver = 2000 defaultLruEventDriver = 2000
) )
const (
defaultWaitTime = 20 * time.Minute
)
type CacheInterface interface { type CacheInterface interface {
Del() error Del() error
Get(key *proto.BaseKey) (structure.KeyBaseInterface, bool) Get(key *proto.BaseKey) (structure.KeyBaseInterface, bool)