chore: make routine loop simpler

sudoblockio · Mar 20, 2023 · d88ad93 · d88ad93
1 parent f89eea6
commit d88ad93
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/routines/routines.go b/src/routines/routines.go
@@ -80,7 +80,6 @@ func RoutinesCron(routines []func(), sleepDuration time.Duration) {
 	}
 }
 
-
 func LoopRoutine[M any, O any](Crud *crud.Crud[M, O], routines []func(*M)) {
 	i := 1
 	skip := i * config.Config.RoutinesBatchSize
@@ -105,9 +104,8 @@ func LoopRoutine[M any, O any](Crud *crud.Crud[M, O], routines []func(*M)) {
 
 		zap.S().Info("Starting skip=", skip, " limit=", limit, " table=", Crud.TableName, " workerId=", i)
 		for i := 0; i < len(*routineItems); i++ {
-			var item *M
-			item = &(*routineItems)[i]
 			for _, r := range routines {
+				item := &(*routineItems)[i]
 				r(item)
 			}
 		}
@@ -117,7 +115,6 @@ func LoopRoutine[M any, O any](Crud *crud.Crud[M, O], routines []func(*M)) {
 	}
 }
 
-
 //func LoopRoutine[M any, O any](Crud *crud.Crud[M, O], routines []func(*M)) {
 //	var wg sync.WaitGroup
 //	wg.Add(config.Config.RoutinesNumWorkers)
@@ -162,4 +159,4 @@ func LoopRoutine[M any, O any](Crud *crud.Crud[M, O], routines []func(*M)) {
 //		}()
 //	}
 //	wg.Wait()
-//}
+//}