草庐IT

ProcessLead

全部标签

multithreading - Goroutines, channels select 语句

我在构建我的goroutines和channel时遇到问题。我的select语句在所有goroutine完成之前一直退出,我知道问题出在我发送完成信号的地方。我应该在哪里发送完成信号。funcstartWorker(okchanLeadRes,errchanLeadResErr,quitchanint,verbosebool,wg*sync.WaitGroup){varresultsProcessResultsdeferwg.Done()log.Info("Starting...")start:=time.Now()for{select{caselead:=