Go Goes

50 строк кода для создания очень простого пула Goroutines — Go

Установка

go get -u github.com/yoojia/go-goes

Зависимости

[[constraint]]
  name = "github.com/yoojia/go-goes"
  version = "0.1.0"

Пример использования

Три шага:

1. Создайте GoesPool;
2. Запустите пул корутин;
3. Добавьте задачи с помощью метода Add;

// Укажите создание пула корутин с 100 рабочими корутинами
pool := goes.NewGoesPoolDefault(100)
// Запуск
pool.Start()

// Остановка пула корутин, блокировка до завершения всех задач
defer pool.Shutdown()

var wg sync.WaitGroup

ЗАДАЧИ := int(1000 * 100)
for i := 0; i < ЗАДАЧИ; i++ {
    wg.Add(1)
    // Используйте метод Add для добавления задачи в пул корутин
    pool.Add(func() {
        wg.Done()
    })
}

wg.Wait()

Внимание

Необходимо обратить внимание на следующие моменты:

1. Обязательно вызывайте метод Start для запуска пула корутин, иначе задачи, добавленные через метод Add, не будут выполнены;
2. Метод Shutdown следует вызывать после метода Start, иначе он будет блокировать выполнение и никогда не вернёт управление;
3. При использовании метода Add, если пул корутин уже полон, выполнение этого метода будет заблокировано до тех пор, пока в пуле не освободится место для новой корутины.

Проекты

Этот проект одновременно поддерживается на следующих двух платформах для хранения исходного кода:

• Microsoft GitHub: github.com/yoojia/go-goes
• Gitee: gitee.com/yoojia/go-goes

Лицензия

Этот пакет лицензируется под Apache License 2.0. Подробнее см. LICENSE.