소스 검색

全局waitgroup超时时间改成time.time

dcsunny 4 년 전
부모
커밋
5284eb304b
1개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 2 2
      common/global_wait_group.go

+ 2 - 2
common/global_wait_group.go

@@ -96,8 +96,8 @@ func (this *globalWaitGroup) Done() {
 	this.wg.Done()
 }
 
-func (this *globalWaitGroup) SetTimeout(timeout *time.Time) {
-	if timeout == nil {
+func (this *globalWaitGroup) SetTimeout(timeout time.Time) {
+	if timeout.Unix() <= 0 {
 		return
 	}
 	this.lock.Lock()