aboutsummaryrefslogtreecommitdiff
path: root/weed/util/lock_table_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/util/lock_table_test.go')
-rw-r--r--weed/util/lock_table_test.go42
1 files changed, 0 insertions, 42 deletions
diff --git a/weed/util/lock_table_test.go b/weed/util/lock_table_test.go
deleted file mode 100644
index 001fa0bdf..000000000
--- a/weed/util/lock_table_test.go
+++ /dev/null
@@ -1,42 +0,0 @@
-package util
-
-import (
- "fmt"
- "math/rand"
- "sync"
- "testing"
- "time"
-)
-
-func TestOrderedLock(t *testing.T) {
- lt := NewLockTable[string]()
-
- var wg sync.WaitGroup
- // Simulate transactions requesting locks
- for i := 1; i <= 50; i++ {
- wg.Add(1)
- go func(i int) {
- defer wg.Done()
- key := "resource"
- lockType := SharedLock
- if i%5 == 0 {
- lockType = ExclusiveLock
- }
-
- // Simulate attempting to acquire the lock
- lock := lt.AcquireLock("", key, lockType)
-
- // Lock acquired, perform some work
- fmt.Printf("ActiveLock %d acquired lock %v\n", lock.ID, lockType)
-
- // Simulate some work
- time.Sleep(time.Duration(rand.Int31n(10)*10) * time.Millisecond)
-
- // Release the lock
- lt.ReleaseLock(key, lock)
- fmt.Printf("ActiveLock %d released lock %v\n", lock.ID, lockType)
- }(i)
- }
-
- wg.Wait()
-}