Compare commits

...

1 Commits

Author SHA1 Message Date
3671b9f80a 调整 exegroup: 按照和启动相反的顺序终止 Actor; 2023-03-29 17:45:04 +08:00

View File

@@ -131,12 +131,12 @@ func (g *Group) wait(c chan error, cancel context.CancelFunc) (err error) {
ctx, cancel = context.WithTimeout(context.Background(), g.cfg.stopTimeout) ctx, cancel = context.WithTimeout(context.Background(), g.cfg.stopTimeout)
defer cancel() defer cancel()
} }
for _, m := range g.actors { for i := len(g.actors) - 1; i >= 0; i-- {
if m.stopFunc != nil { if g.actors[i].stopFunc != nil {
if g.cfg.concurrentStop { if g.cfg.concurrentStop {
go m.stopFunc(ctx) go g.actors[i].stopFunc(ctx)
} else { } else {
m.stopFunc(ctx) g.actors[i].stopFunc(ctx)
} }
} }
} }