Сколько потоков запускается в Runtime приложения

1️⃣ Как кратко ответить

Количество потоков, запускаемых в Runtime Go-приложения, зависит от количества доступных процессоров и значения переменной окружения GOMAXPROCS, которая определяет максимальное количество операционных системных потоков, которые могут одновременно выполнять пользовательский код Go.

2️⃣ Подробное объяснение темы

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

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

Что такое GOMAXPROCS?

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

Как это работает?

Когда вы запускаете Go-приложение, Go Runtime создает пул операционных системных потоков. Эти потоки используются для выполнения горутин. Планировщик Go распределяет горутины по этим потокам, чтобы обеспечить эффективное использование процессорного времени.

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

package main
​
import (
    "fmt"
    "runtime"
)
​
func main() {
    // Устанавливаем GOMAXPROCS равным 1
    runtime.GOMAXPROCS(1)
​
    // Выводим текущее значение GOMAXPROCS
    fmt.Println("GOMAXPROCS is set to:", runtime.GOMAXPROCS(0))
​
    // Запускаем несколько горутин
    for i := 0; i < 10; i++ {
        go func(n int) {
            fmt.Println(n)
        }(i)
    }
​
    // Ожидаем завершения всех горутин
    var input string
    fmt.Scanln(&input)
}

Объяснение кода:

• runtime.GOMAXPROCS(1): Устанавливает GOMAXPROCS равным 1, что означает, что только один операционный системный поток будет использоваться для выполнения горутин одновременно.
• runtime.GOMAXPROCS(0): Возвращает текущее значение GOMAXPROCS без изменения его.
• go func(n int) { ... }(i): Запускает анонимную функцию как горутину, передавая ей текущий индекс i.
• fmt.Scanln(&input): Используется для ожидания завершения всех горутин, чтобы программа не завершилась раньше времени.

Зачем это нужно?

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