diff --git a/pkg/lru/woker_test.go b/pkg/lru/woker_test.go index c80bee2..f4bf3df 100644 --- a/pkg/lru/woker_test.go +++ b/pkg/lru/woker_test.go @@ -5,7 +5,7 @@ import ( "testing" "time" - "gitee.com/wheat-os/wheatCache/pkg/event" + "gitee.com/wheat-os/wheatCache/pkg/event2" "gitee.com/wheat-os/wheatCache/pkg/logx" "gitee.com/wheat-os/wheatCache/pkg/proto" "gitee.com/wheat-os/wheatCache/pkg/structure/stringx" @@ -15,9 +15,9 @@ import ( func TestWorker(t *testing.T) { ctx := context.Background() lru := NewLRUCache() - produce := event.NewProduce(lru.GetDriver()) + produce := event2.NewProduce(lru.GetDriver()) workEvent := produce.NewEvent(OptionEventName) - workEvent.SetValue(WorkFuncEventKey, event.EventWorkFunc(func() (interface{}, error) { + workEvent.SetValue(event2.WorkFuncEventKey, event2.EventWorkFunc(func() (interface{}, error) { v1 := stringx.NewStringSingle() key := proto.BaseKey{ Key: "v1", @@ -36,11 +36,11 @@ func TestWorker(t *testing.T) { func TestSingleCache_DelToClearSize(t *testing.T) { ctx := context.Background() lru := NewLRUCache() - produce := event.NewProduce(lru.GetDriver()) + produce := event2.NewProduce(lru.GetDriver()) for i := int32(20000); i > 0; i-- { workEvent := produce.NewEvent(OptionEventName) - workEvent.SetValue(WorkFuncEventKey, event.EventWorkFunc(func() (interface{}, error) { + workEvent.SetValue(event2.WorkFuncEventKey, event2.EventWorkFunc(func() (interface{}, error) { v1 := stringx.NewStringSingle() key := proto.BaseKey{ Key: string(i), @@ -53,7 +53,7 @@ func TestSingleCache_DelToClearSize(t *testing.T) { workEvent.InitWaitEvent() produce.Call(ctx, workEvent) workEvent.StartWaitEvent(2 * time.Second) - produce.Recovery(workEvent) + workEvent.Recovery() } logx.Info("start size is %d", lru.nowSize)