Explorar o código

部分延迟、参数调整

maxiaoshan hai 1 ano
pai
achega
e455d473c7
Modificáronse 3 ficheiros con 4 adicións e 4 borrados
  1. 1 1
      src/spider/history.go
  2. 2 2
      src/spider/msgservice.go
  3. 1 1
      src/spider/spider.go

+ 1 - 1
src/spider/history.go

@@ -150,5 +150,5 @@ func GetHistoryDownloadSpider() {
 	}
 	wg.Wait()
 	//time.AfterFunc(time.Second*30, GetHistoryDownloadSpider)
-	time.AfterFunc(time.Minute*30, GetHistoryDownloadSpider)
+	time.AfterFunc(time.Minute*10, GetHistoryDownloadSpider)
 }

+ 2 - 2
src/spider/msgservice.go

@@ -52,8 +52,8 @@ func InitMsgClientFile(serveraddr, name string) {
 		MsgServerAddr:   serveraddr,
 		EventHandler:    processeventFile,
 		CanHandleEvents: []int{mu.SERVICE_DOWNLOAD_APPEND_NODE, mu.SERVICE_DOWNLOAD_DELETE_NODE},
-		ReadBufferSize:  200,
-		WriteBufferSize: 200,
+		ReadBufferSize:  500,
+		WriteBufferSize: 500,
 	})
 	go gc4AlldownloaderFile()
 }

+ 1 - 1
src/spider/spider.go

@@ -840,7 +840,7 @@ func GetListDataDownloadDetail() {
 	Allspiders2.Range(func(k, v interface{}) bool {
 		sp := v.(*Spider)
 		go sp.DownloadHighDetail(true)
-		time.Sleep(1 * time.Second)
+		time.Sleep(200 * time.Millisecond)
 		return true
 	})
 }