Method TestShardedLockKeyParallel

lockstore/store_test.go:176–202

(c *C)

}

func (s *LockStoreSuite) TestShardedLockKeyParallel(c *C) {
	key := "test-key-parallel"
	const count = 10
	storeRaw := New(LockStoreOptions{Granularity: ShardedGranularity, LockCount: count})
	store := storeRaw.(*_LockStoreImp)
	period := time.Second
	wg := sync.WaitGroup{}

	// rnd is not thread-safe
	lock := sync.Mutex{}
	rnd := rand.New(rand.NewSource(time.Now().Unix()))
	// this test will take approximately 10 sec
	for i := 0; i < 10; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			store.Lock(key)
			lock.Lock()
			jitter := period/2 + time.Duration(rnd.Int63n(int64(period)))
			lock.Unlock()
			time.Sleep(jitter)
			store.Unlock(key)
		}()
	}

	wg.Wait()
}

func (s *LockStoreSuite) TestShardedLockKeyMultiple(c *C) {
	const count = 10