diff --git a/pkg/controller/batchrelease/batchrelease_controller.go b/pkg/controller/batchrelease/batchrelease_controller.go
index 98ed293e..f3a722e9 100644
--- a/pkg/controller/batchrelease/batchrelease_controller.go
+++ b/pkg/controller/batchrelease/batchrelease_controller.go
@@ -52,6 +52,8 @@ var (
 )
 
 func init() {
+	flag.IntVar(&concurrentReconciles, "batchrelease-workers", 3, "Max concurrent workers for batchRelease controller.")
+
 	watchedWorkload = sync.Map{}
 	watchedWorkload.LoadOrStore(util.ControllerKindDep.String(), struct{}{})
 	watchedWorkload.LoadOrStore(util.ControllerKindSts.String(), struct{}{})
diff --git a/pkg/controller/rollout/rollout_controller.go b/pkg/controller/rollout/rollout_controller.go
index e87d25bb..97519889 100644
--- a/pkg/controller/rollout/rollout_controller.go
+++ b/pkg/controller/rollout/rollout_controller.go
@@ -18,6 +18,7 @@ package rollout
 
 import (
 	"context"
+	"flag"
 	"sync"
 	"time"
 
@@ -42,6 +43,8 @@ var (
 )
 
 func init() {
+	flag.IntVar(&concurrentReconciles, "rollout-workers", 3, "Max concurrent workers for rollout controller.")
+
 	watchedWorkload = sync.Map{}
 	watchedWorkload.LoadOrStore(util.ControllerKindDep.String(), struct{}{})
 	watchedWorkload.LoadOrStore(util.ControllerKindSts.String(), struct{}{})