annotation wg.wait

2026-08-28 19:47:14 +08:00 · 2022-10-23 16:14:33 +08:00
parent f6ae2dd00a
commit 14405d56a6
1 changed files with 2 additions and 2 deletions
@@ -670,8 +670,8 @@ func (r *localRunner) start() {
 		close(r.controller.rebalance)
 		r.wgMu.Unlock()

-		// wait for goroutines before closing
-		r.wg.Wait()
+		//// wait for goroutines before closing
+		//r.wg.Wait()

 		close(r.doneChan)