Refactoring wait group to analyze

kitabisa · Mar 16, 2021 · a2bb588 · a2bb588
1 parent 3f6980e
commit a2bb588
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/internal/runner/runner.go b/internal/runner/runner.go
@@ -63,13 +63,13 @@ func New(options *common.Options) {
 
 	con := options.Concurrency
 	swg := sizedwaitgroup.New(con)
-	for i := 0; i < con; i++ {
-		swg.Add()
-		go func() {
-			defer swg.Done()
+	go func() {
+		for log := range jobs {
+			swg.Add()
+			go func(line *gonx.Entry) {
+				defer swg.Done()
 
-			for log := range jobs {
-				threat, obj := teler.Analyze(options, log)
+				threat, obj := teler.Analyze(options, line)
 
 				if threat {
 					if metric {
@@ -105,9 +105,9 @@ func New(options *common.Options) {
 
 					alert.New(options, common.Version, obj)
 				}
-			}
-		}()
-	}
+			}(log)
+		}
+	}()
 
 	if options.Stdin {
 		input = os.Stdin