修复task泄露

signal包里面SetTimeout方法并发时可能会出现task close以后执行start导致泄露
This commit is contained in:
isluckys 2025-06-19 01:56:17 +08:00 committed by GitHub
parent fbae89d017
commit f34e905902
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -67,9 +67,9 @@ func (t *ActivityTimer) SetTimeout(timeout time.Duration) {
t.checkTask.Close() t.checkTask.Close()
} }
t.checkTask = checkTask t.checkTask = checkTask
t.Unlock()
t.Update() t.Update()
common.Must(checkTask.Start()) common.Must(checkTask.Start())
t.Unlock()
} }
func CancelAfterInactivity(ctx context.Context, cancel context.CancelFunc, timeout time.Duration) *ActivityTimer { func CancelAfterInactivity(ctx context.Context, cancel context.CancelFunc, timeout time.Duration) *ActivityTimer {