Function TestStopUnblocksAllWaiters

pkg/flushqueues/exclusivequeues_test.go:216–237

TestStopUnblocksAllWaiters verifies that calling Stop on an empty queue unblocks all goroutines waiting in Dequeue, returning zero values.

(t *testing.T)

// TestStopUnblocksAllWaiters verifies that calling Stop on an empty queue
// unblocks all goroutines waiting in Dequeue, returning zero values.
func TestStopUnblocksAllWaiters(t *testing.T) {
	q := New[mockOp](nil)
	numWorkers := 5

	var allStarted sync.WaitGroup
	allStarted.Add(numWorkers)

	var workers sync.WaitGroup
	for i := range numWorkers {
		workers.Add(1)
		go func() {
			defer workers.Done()
			allStarted.Done()
			op := q.Dequeue()
			assert.Equal(t, mockOp{}, op, "worker %d: expected zero value from closed queue", i)
		}()
	}

	allStarted.Wait()
	q.Stop()
	workers.Wait()
}