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