可以用waitgroup优化下 #4
Description
func (downloader *downloader) Stop() {
//放入线程数量次的停止信号,等到无阻塞时说明爬虫线程都已经停止了
for i := 0; i < FETCH_THREAD_NUMBER; i++ {
downloader.stopSignal <- true
}
{{ message }}
func (downloader *downloader) Stop() {
//放入线程数量次的停止信号,等到无阻塞时说明爬虫线程都已经停止了
for i := 0; i < FETCH_THREAD_NUMBER; i++ {
downloader.stopSignal <- true
}