Compare commits

..

1 Commits

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

View File

@@ -103,7 +103,7 @@ func (g *Group) validate() {
}
for _, actor := range g.actors {
if actor.goFunc == nil {
panic(actor.name + "has nil goFunc")
panic(actor.name + " has nil goFunc")
}
}
}
@@ -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)
defer cancel()
}
for _, m := range g.actors {
if m.stopFunc != nil {
for i := len(g.actors) - 1; i >= 0; i-- {
if g.actors[i].stopFunc != nil {
if g.cfg.concurrentStop {
go m.stopFunc(ctx)
go g.actors[i].stopFunc(ctx)
} else {
m.stopFunc(ctx)
g.actors[i].stopFunc(ctx)
}
}
}