leftovers round #2

smartcontractkit · Sep 8, 2023 · c97755a · c97755a
1 parent 84ec47d
commit c97755a
Showing 1 changed file with 2 additions and 12 deletions.
diff --git a/core/utils/thread_control.go b/core/utils/thread_control.go
@@ -33,9 +33,9 @@ type threadControl struct {
 }
 
 func (tc *threadControl) Go(fn func(context.Context)) {
-	tc.add()
+	tc.threadsWG.Add(1)
 	go func() {
-		defer tc.done()
+		defer tc.threadsWG.Done()
 		ctx, cancel := tc.stop.NewCtx()
 		defer cancel()
 		fn(ctx)
@@ -46,13 +46,3 @@ func (tc *threadControl) Close() {
 	close(tc.stop)
 	tc.threadsWG.Wait()
 }
-
-func (tc *threadControl) add() {
-	tc.running.Add(1)
-	tc.threadsWG.Add(1)
-}
-
-func (tc *threadControl) done() {
-	tc.running.Add(-1)
-	tc.threadsWG.Done()
-}