Function TestHandleStore_Concurrency

handle_test.go:216–258

(t *testing.T)

}

func TestHandleStore_Concurrency(t *testing.T) {
	hs := newHandleStore()
	const numGoroutines = 10
	const numOpsPerGoroutine = 100

	var wg sync.WaitGroup
	var successCount int64

	// Test concurrent operations
	for i := 0; i < numGoroutines; i++ {
		wg.Add(1)
		go func(goroutineID int) {
			defer wg.Done()

			// Each goroutine does store/load/delete operations
			for j := 0; j < numOpsPerGoroutine; j++ {
				value := goroutineID*1000 + j

				// Store
				id := hs.Store(value)

				// Load and verify
				loadedValue, ok := hs.Load(id)
				if ok && loadedValue == value {
					atomic.AddInt64(&successCount, 1)
				}

				// Delete
				hs.Delete(id)
			}
		}(i)
	}

	wg.Wait()

	// Verify all operations succeeded
	expectedSuccesses := int64(numGoroutines * numOpsPerGoroutine)
	assert.Equal(t, expectedSuccesses, successCount)

	// Final cleanup
	hs.Clear()
	assert.Equal(t, 0, hs.Count())
}

func TestHandleStore_ZeroValues(t *testing.T) {
	hs := newHandleStore()