Как можно управлять горутинами и сгоняются ли они все в один поток?

Что такое горутины и как они работают

Горутина — это легковесная единица выполнения в Go, которая запускается с помощью ключевого слова go. В отличие от потоков ОС, горутины имеют маленький стартовый стек (несколько килобайт) и управляются планировщиком Go, а не операционной системой. Это позволяет создавать тысячи горутин без значительных накладных расходов.

Планировщик Go использует модель M:N, где M — потоки ОС, а N — горутины. Горутины распределяются по доступным потокам, и при необходимости планировщик может переносить их между потоками. По умолчанию число потоков равно числу логических ядер процессора, но его можно изменить через переменную окружения GOMAXPROCS или одноимённую функцию.

Основные способы управления горутинами

• Каналы — основной механизм синхронизации и передачи данных между горутинами. Через каналы можно сигнализировать о завершении работы или передавать результаты.
• WaitGroup — позволяет дождаться завершения группы горутин. Удобно, когда нужно запустить несколько параллельных задач и подождать их окончания.
• Контекст (context.Context) — используется для отмены горутин, передачи дедлайнов и значений. Позволяет корректно завершать долгие операции.
• Атомарные операции — для простых счётчиков и флагов можно использовать пакет sync/atomic.

Пример управления горутинами

package main

import (
    "fmt"
    "sync"
    "time"
)

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Горутина %d начала работу\n", id)
    time.Sleep(time.Second)
    fmt.Printf("Горутина %d завершилась\n", id)
}

func main() {
    var wg sync.WaitGroup
    for i := 1; i <= 3; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }
    wg.Wait()
    fmt.Println("Все горутины завершены")
}

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

Распределение по потокам

Горутины не сгоняются в один поток. Планировщик Go распределяет их по нескольким потокам ОС, что позволяет использовать многоядерные процессоры. Однако если установить GOMAXPROCS=1, все горутины будут выполняться на одном потоке, но это не рекомендуется для производительности, так как теряется параллелизм.

Важно понимать, что горутины — это не потоки, и их стоимость создания и переключения значительно ниже. Поэтому в Go принято использовать горутины для конкурентности, а не создавать потоки вручную.

Вывод

Управление горутинами в Go осуществляется через каналы, WaitGroup, контексты и атомарные операции. Горутины распределяются по нескольким потокам ОС благодаря планировщику, что позволяет эффективно использовать многоядерные системы. Знание этих механизмов необходимо для написания надёжных конкурентных программ на Go.