task manager graceful shutdown support

This commit is contained in:
guoxingyong 2021-05-26 10:37:16 +08:00
parent 8a193c5004
commit 7419ad952d

View File

@ -593,7 +593,7 @@ func (m *taskManager) StopTask() {
// GracefulShutdown wait all task done
func (m *taskManager) GracefulShutdown() <-chan struct{} {
done := make(chan struct{}, 0)
done := make(chan struct{})
go func() {
m.stop <- true
m.wait.Wait()