Support set the num of maxConcurrentReconciles (#4405)

Signed-off-by: jiuyu <guotongyu.gty@alibaba-inc.com>
Co-authored-by: jiuyu <guotongyu.gty@alibaba-inc.com>

Author: Syspretor

charts/fluid/fluid/templates/controller/thinruntime_controller.yaml

@@ -42,6 +42,7 @@ spec:
           - --development=false
           - --pprof-addr=:6060
           - --enable-leader-election
+          - --runtime-workers={{ .Values.runtime.thin.runtimeWorkers }}
           - --leader-election-namespace={{ include "fluid.namespace" . }}
         command: ["thinruntime-controller", "start"]
         env:

charts/fluid/fluid/values.yaml

@@ -212,6 +212,7 @@ runtime:
     #     cpu: 1000m
     #     memory: 512Mi
     enabled: false
+    runtimeWorkers: 3
     controller:
       imagePrefix: *defaultImagePrefix
       imageName: thinruntime-controller

cmd/thin/app/thin.go

@@ -84,6 +84,7 @@ func init() {
 	startCmd.Flags().StringVarP(&pprofAddr, "pprof-addr", "", "", "The address for pprof to use while exporting profiling results")
 	startCmd.Flags().BoolVarP(&development, "development", "", true, "Enable development mode for fluid controller.")
 	startCmd.Flags().BoolVar(&eventDriven, "event-driven", true, "The reconciler's loop strategy. if it's false, it indicates period driven.")
+	startCmd.Flags().IntVar(&maxConcurrentReconciles, "runtime-workers", 3, "Set max concurrent workers for ThinRuntime controller")
 	startCmd.Flags().Float32VarP(&kubeClientQPS, "kube-api-qps", "", 20, "QPS to use while talking with kubernetes apiserver.")   // 20 is the default qps in controller-runtime
 	startCmd.Flags().IntVarP(&kubeClientBurst, "kube-api-burst", "", 30, "Burst to use while talking with kubernetes apiserver.") // 30 is the default burst in controller-runtime
 	startCmd.Flags().StringVar(&controllerWorkqueueDefaultSyncBackoffStr, "workqueue-default-sync-backoff", "5ms", "base backoff period for failed reconcilation in controller's workqueue")