Backend Portal | Программирование

Паттерн, который я использую в Go для запуска долгоживущих сервисов или фоновых процессов.

Идея в том, что сервис реализует всего один блокирующий метод Run(ctx), который делает всю основную работу: обслуживает запросы, следит за изменениями и так далее.
Чтобы его остановить, достаточно отменить контекст.

За счет этого интерфейс получается очень простым. Если нужен неблокирующий старт/стоп, их можно собрать прямо в том месте, где они нужны:

stop() -> просто используйте context.WithCancel. Возвращаемый cancel() и будет вашей функцией остановки.

start() -> оберните Run(ctx) в замыкание и запустите как goroutine. Владельцем goroutine остается вызывающая сторона, а не сам сервис. Это позволяет держать сервис простым и предсказуемым.

Также можно добавить канал done, чтобы понимать, когда Run полностью завершился, для graceful shutdown.

Этот подход особенно хорош, когда нужно управлять сразу многими такими сервисами. Если запускать их через errgroup, вы получаете:

- автоматическую отмену всех сервисов, если один из них завершился с ошибкой
- один общий Wait() для ожидания завершения всех сервисов

// Service only implements a blocking Run(ctx). Cancel the context to stop it.

type Service struct{}

func (s *Service) Run(ctx context.Context) error {
  fmt.Println("running")

  // Do busy work: serve requests, watch for changes, etc.
  // Return when ctx is canceled
  <-ctx.Done()

  fmt.Println("stopped")
  return nil
}

func main() {
  ctx := context.Background()
  s := &Service{}

  // 1. blocking: just call Run with a context
  ctx1, _ := context.WithTimeout(ctx, 2*time.Second) // canceled after 2 seconds for demo
  err := s.Run(ctx1)

  // 2. non-blocking: implement ad-hoc start/stop and wait for completion if needed
  ctx2, stop := context.WithCancel(ctx)
  done := make(chan error, 1)
  start := func() { // start() wrapper to send the result of Run to done channel
    done <- s.Run(ctx2)
  }

  go start() // non-blocking start in a goroutine
  time.Sleep(2 * time.Second)
  stop()      // cancel ctx to signal shutdown
  err = <-done // wait for Run to return if needed
}

👉

@BackendPortal

Please open Telegram to view this post