Function TestWantConnQueue_len_Concurrent

internal/pool/want_conn_test.go:875–917

TestWantConnQueue_len_Concurrent tests len() thread safety.

(t *testing.T)

// TestWantConnQueue_len_Concurrent tests len() thread safety.
func TestWantConnQueue_len_Concurrent(t *testing.T) {
	q := newWantConnQueue()
	const numReaders = 10
	const numWriters = 5
	const operations = 100

	var wg sync.WaitGroup

	// Multiple readers calling len()
	for i := 0; i < numReaders; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for j := 0; j < operations; j++ {
				_ = q.len() // Just read, don't care about value
				time.Sleep(time.Microsecond)
			}
		}()
	}

	// Writers enqueueing
	for i := 0; i < numWriters; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			for j := 0; j < operations; j++ {
				w := &wantConn{
					ctx:    context.Background(),
					result: make(chan wantConnResult, 1),
				}
				q.enqueue(w)
			}
		}()
	}

	wg.Wait()

	// Verify final length is correct
	expectedLength := numWriters * operations
	if length := q.len(); length != expectedLength {
		t.Errorf("final queue len() = %d, want %d", length, expectedLength)
	}
}