Method triggerStop

service/pool_impl.go:158–179

(shutdownContext context.Context)

}

func (p *pool) triggerStop(shutdownContext context.Context) {
	p.mutex.Lock()
	if p.stopping {
		p.mutex.Unlock()
		return
	}
	p.stopping = true
	svc := p.services
	p.mutex.Unlock()

	wg := &sync.WaitGroup{}
	wg.Add(len(svc))
	for _, s := range svc {
		service := s
		l := p.lifecycles[service]
		go func() {
			defer wg.Done()
			l.Stop(shutdownContext)
		}()
	}
	wg.Wait()
}