Function TestSendProcess_ConcurrentShutdown

core/pool/pool_test.go:430–455

(t *testing.T)

}

func TestSendProcess_ConcurrentShutdown(t *testing.T) {
	ctx, cancel := context.WithCancel(context.Background())
	pool := newTestBasePool(ctx, cancel)

	var ext sync.WaitGroup
	for i := 0; i < 200; i++ {
		ext.Add(1)
		go func() {
			defer ext.Done()
			pool.sendProcess(newTestBaseline())
		}()
	}

	time.Sleep(2 * time.Millisecond)
	cancel()

	go func() {
		for range pool.processCh {
		}
	}()

	mustFinish(t, 5*time.Second, "concurrent sendProcess+cancel hung", func() {
		ext.Wait()
	})
	close(pool.processCh)
}

// ---------------------------------------------------------------------------
// putToOutput