foo.go

// Run workers that process the queue.
func (c *Controller) startQueueWorkers() {
  ctx, cancel := context.WithCancel(context.Background())

  go func() {
    // Wait for stop and then cancel
    <-c.stopChan
    cancel()
  }()

  for i := 1; i <= maxQueueWorkers; i++ {
    go func() {
      for {
        task, err := c.taskQueue.Poll(ctx)
        if err != nil {
          if !errors.Is(err, context.Canceled) {
            logger.Err(err).Msg("Failed polling queue")
          }
          continue
        }
        
        err = c.handleTask(ctx, task)
        if err != nil {
          c.scheduleRetry(task)
          continue
        }
      }
    }()
  }
}