Method TestWaitMultipleWaiters

asyncbuffer/cond_test.go:55–94

TestWaitMultipleWaiters tests that multiple waiters can be unblocked by a single tick

()

// TestWaitMultipleWaiters tests that multiple waiters can be unblocked by a single tick
func (s *TestCondSuite) TestWaitMultipleWaiters() {
	const numWaiters = 10

	var wg sync.WaitGroup
	var startWg sync.WaitGroup
	results := make([]bool, numWaiters)

	// Capture cursor before starting waiters
	cursor := s.cond.Cursor()

	// Start multiple waiters
	for i := range numWaiters {
		wg.Add(1)
		startWg.Add(1)
		go func(index int) {
			defer wg.Done()
			startWg.Done() // Signal that this goroutine is ready
			s.cond.Wait(cursor)
			results[index] = true
		}(i)
	}

	// Wait for all goroutines to start waiting
	startWg.Wait()

	// Wait for all waiters to complete
	var done atomic.Bool
	go func() {
		s.cond.Tick() // Signal that execution can proceed
		wg.Wait()
		done.Store(true)
	}()

	s.Require().Eventually(done.Load, 200*time.Millisecond, 10*time.Millisecond)

	// Check that all waiters were unblocked
	for _, completed := range results {
		s.Require().True(completed)
	}
}

// TestClose tests the behavior of the Cond when closed
func (s *TestCondSuite) TestClose() {