refactor: use WaitGroup.Go to simplify code

block/internal/executing/executor.go

@@ -154,11 +154,7 @@ func (e *Executor) Start(ctx context.Context) error {
 	}
 
 	// Start execution loop
-	e.wg.Add(1)
-	go func() {
-		defer e.wg.Done()
-		e.executionLoop()
-	}()
+	e.wg.Go(e.executionLoop)
 
 	e.logger.Info().Msg("executor started")
 	return nil

block/internal/reaping/reaper.go

@@ -78,11 +78,7 @@ func (r *Reaper) Start(ctx context.Context) error {
 	r.ctx, r.cancel = context.WithCancel(ctx)
 
 	// Start reaper loop
-	r.wg.Add(1)
-	go func() {
-		defer r.wg.Done()
-		r.reaperLoop()
-	}()
+	r.wg.Go(r.reaperLoop)
 
 	r.logger.Info().Dur("interval", r.interval).Msg("reaper started")
 	return nil

block/internal/syncing/raft_retriever.go

@@ -71,11 +71,9 @@ func (r *raftRetriever) Start(ctx context.Context) error {
 	applyCh := make(chan raft.RaftApplyMsg, 100)
 	r.raftNode.SetApplyCallback(applyCh)
 
-	r.wg.Add(1)
-	go func() {
-		defer r.wg.Done()
+	r.wg.Go(func() {
 		r.raftApplyLoop(ctx, applyCh)
-	}()
+	})
 	return nil
 }
 

pkg/da/selector_test.go

@@ -137,14 +137,12 @@ func TestNoOpSelector_Concurrent(t *testing.T) {
 	var wg sync.WaitGroup
 
 	for i := 0; i < numGoroutines; i++ {
-		wg.Add(1)
-		go func() {
-			defer wg.Done()
+		wg.Go(func() {
 			for j := 0; j < 100; j++ {
 				addr := selector.Next()
 				assert.Empty(t, addr)
 			}
-		}()
+		})
 	}
 
 	wg.Wait()