run shutdownListeners concurrently

vbauerster · Aug 17, 2024 · c31e10e · c31e10e
1 parent ff80242
commit c31e10e
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/bar.go b/bar.go
@@ -424,13 +424,17 @@ func (b *Bar) serve(bs *bState) {
 		case op := <-b.operateState:
 			op(bs)
 		case <-b.ctx.Done():
-			shutdownListeners := bs.shutdownListeners
+			for _, d := range bs.shutdownListeners {
+				b.container.bwg.Add(1)
+				d := d
+				go func() {
+					d.OnShutdown()
+					b.container.bwg.Done()
+				}()
+			}
 			bs.aborted = !bs.completed()
 			b.bs = bs
 			close(b.bsOk)
-			for _, d := range shutdownListeners {
-				d.OnShutdown()
-			}
 			b.container.bwg.Done()
 			return
 		}