Method RunWithLifecycle

service/pool_impl.go:43–87

(lifecycle Lifecycle)

}

func (p *pool) RunWithLifecycle(lifecycle Lifecycle) error {
	p.mutex.Lock()
	if p.running {
		p.mutex.Unlock()
		panic("bug: pool already running, cannot run again")
	}
	p.logger.Info(message.NewMessage(message.MServicesStarting, "Services are starting..."))
	p.stopComplete = make(chan struct{}, len(p.services))
	p.running = true
	p.stopping = false
	p.mutex.Unlock()
	defer func() {
		p.mutex.Lock()
		p.running = false
		p.mutex.Unlock()
	}()

	for _, service := range p.services {
		p.runService(service)
	}

	stopped := false
	startedServices := len(p.services)
	finished := false
	for i := 0; i < len(p.services); i++ {
		select {
		case <-p.startupComplete:
		case <-p.stopComplete:
			stopped = true
			startedServices--
			finished = true
		}
		if finished {
			break
		}
	}

	startedServices = p.processRunning(lifecycle, stopped, startedServices)

	for i := 0; i < startedServices; i++ {
		<-p.stopComplete
	}
	p.logger.Info(message.NewMessage(message.MServicesStopped, "All services have stopped."))
	return p.lastError
}

func (p *pool) processRunning(lifecycle Lifecycle, stopped bool, startedServices int) int {
	if !stopped {