diff options
Diffstat (limited to 'weed/util/lock_table_test.go')
| -rw-r--r-- | weed/util/lock_table_test.go | 42 |
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() -} |
