Method TestRapidTicksAndWaits

asyncbuffer/cond_test.go:107–141

()

}

func (s *TestCondSuite) TestRapidTicksAndWaits() {
	const iterations = 1000

	var wg sync.WaitGroup

	// Start a goroutine that will rapidly tick
	wg.Go(func() {
		timeTicker := time.Tick(time.Microsecond)

		for range iterations {
			<-timeTicker
			s.cond.Tick()
		}

		s.cond.Close() // Close after all ticks
	})

	// Start multiple waiters
	for range 10 {
		wg.Go(func() {
			cursor := s.cond.Cursor()
			for range iterations / 10 {
				cursor = s.cond.Wait(cursor)
			}
		})
	}

	var done atomic.Bool
	go func() {
		wg.Wait()
		done.Store(true)
	}()

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

func TestCond(t *testing.T) {
	suite.Run(t, new(TestCondSuite))