Executing Activities in parallel problem

[zhangkyou]

Hi, I use cadence for executing many activities in parallel.The workflow function code is like this:

func sampleMultiParallelWorkflow(ctx workflow.Context) error {
   waitChannel := workflow.NewChannel(ctx)
   ao := workflow.ActivityOptions{
      ScheduleToStartTimeout: time.Second * 30,
      StartToCloseTimeout:    time.Second * 30,
   }
   ctx = workflow.WithActivityOptions(ctx, ao)
   logger := workflow.GetLogger(ctx)
   logger.Info("workflowStart")
   var i int64
   i = 0
   var activityLen int64
   activityLen = 30
   for ; i < activityLen; i++ {
      param := i
      workflow.Go(ctx, func(ctx workflow.Context) {
         var res int64
         err := workflow.ExecuteActivity(ctx, sampleParallelActivity, param).Get(ctx, &res)
         if err != nil {
            logger.Error("Activity failed", zap.Error(err), zap.Int64("param", param))
            msg := fmt.Sprintf("Activity failed.param: %d, err: %s", param, err.Error())
            waitChannel.Send(ctx, msg)
            return
         }
         msg := fmt.Sprintf("Activity Success.param: %d", param)
         waitChannel.Send(ctx, msg)
      })
   }
   logger.Warn("All activity execute.")
   // wait for all of the coroutinue to complete.
   var errMsg string
   var j int64
   j = 0
   for  ; j < activityLen; j++ {
      waitChannel.Receive(ctx, &errMsg)
      logger.Info(errMsg)
   }

   logger.Info("Workflow completed.")
   return nil
}

The workflow function execute 30 activities in parallel.The activity function is like this:

func sampleParallelActivity(ctx context.Context, param int64) (int64, error) {
   logger := activity.GetLogger(ctx)
   acInfo := activity.GetInfo(ctx)
   logger.Info("Activity Start.", zap.Int64("param", param), zap.String("ActivityId", acInfo.ActivityID))
   time.Sleep(time.Second * 10)
   logger.Info("Activity Success.", zap.Int64("param", param), zap.String("ActivityId", acInfo.ActivityID))
   return param, nil
}

WorkflowOptions is:

workflowOptions := client.StartWorkflowOptions{
   ID:                              "parallelTest",
   TaskList:                        ApplicationName,
   ExecutionStartToCloseTimeout:    time.Minute * 10,
   DecisionTaskStartToCloseTimeout: time.Second * 20,
   WorkflowIDReusePolicy: client.WorkflowIDReusePolicyAllowDuplicate,
   CronSchedule: "* * * * *",
}

The worker config is default by cadence-samples project.In this case,2-6 activities of total 30 will be scheduled but not start untill timeout.If the activityLen = 20, all activities can be completed.So in my case, which config can be adjusted to fix this problem?