🔧 Эффективное управление горутинами

Горутины — это то, что открывает перед нами огромные возможности. Однако, с большим количеством задач приходит и необходимость эффективно управлять ими.

Давайте представим ситуацию, когда вам нужно выполнить множество однотипных операций — например, обработку запросов к базе данных, массовую загрузку данных или параллельные вычисления.

С помощью Ants вы создаете пул горутин, который управляет числом параллельных задач, позволяя их выполнять только в пределах установленного лимита.

Например, если вы хотите ограничить количество одновременно выполняющихся горутин до 10:

package main

import (
  "fmt"
  "sync"
  "time"

  "github.com/panjf2000/ants/v2"
)

func main() {
  pool, _ := ants.NewPool(10) // Создаем пул с 10 горутинами
  defer pool.Release()         // Освобождаем ресурсы по завершению

  var wg sync.WaitGroup

  for i := 0; i < 20; i++ { // Добавляем 20 задач
    wg.Add(1)
    pool.Submit(func() {
      defer wg.Done()
      fmt.Println("Задача выполняется")
      time.Sleep(1 * time.Second) // Симуляция работы
    })
  }

  wg.Wait() // Ждем завершения всех задач
  fmt.Println("Все задачи завершены!")
}

Несмотря на то, что добавляем 20 задач, одновременно будут работать только 10, и по мере их завершения пул будет заполняться новыми задачами.

Что ещё умеет Ants:

• Пул горутин обрабатывает паники.

• Можно использовать контексты для отмены задач.

• Можно настраивать пул по ёмкости, числу параллельных задач и времени жизни горутин.

➡️ GitHub библиотеки

🐸Библиотека Go-разработчика

#буст