diff --git a/rlock.go b/rlock.go index a46eb07..178e93c 100644 --- a/rlock.go +++ b/rlock.go @@ -161,13 +161,10 @@ func (r *RLock) renewExpirationSchedulerGoroutine(cancel context.Context, goid u } func (r *RLock) cancelExpirationRenewal(goid uint64) { - fmt.Println("cancel gitid", goid) entryName := r.g.getEntryName(r.Key) - fmt.Println("cancel entryName", entryName) entry, ok := r.g.RenewMap.Get(entryName) if !ok { - fmt.Println("cancel not found", entryName) return } task := entry.(*RenewEntry) @@ -179,7 +176,6 @@ func (r *RLock) cancelExpirationRenewal(goid uint64) { if task.cancelFunc != nil { task.cancelFunc() task.cancelFunc = nil - fmt.Println("call cancel function", entryName) } r.g.RenewMap.Remove(entryName) } diff --git a/rlock_test.go b/rlock_test.go index df179ae..804b57c 100644 --- a/rlock_test.go +++ b/rlock_test.go @@ -119,3 +119,21 @@ func TestPub(t *testing.T) { rdb.Publish(context.Background(), "123-channel", "123") } + +func TestReLock(t *testing.T) { + rdb := redis.NewClient(&redis.Options{ + Addr: "localhost:6379", + Password: "", // no password set + DB: 0, // use default DB + }) + + g := NewGodisson(rdb) + + lock1 := g.NewRLock("hkn") + t.Log(lock1.TryLock(-1, 30000)) + time.Sleep(10 * time.Second) + + lock2 := g.NewRLock("hkn") + t.Log(lock2.TryLock(-1, -1)) + +}