1

Читаю статью про горутины где приводится такой код

package main

import (
    "fmt"
    "time"
)

func main() {
  start := time.Now()
  func() {
    for i:=0; i < 3; i++ {
      fmt.Println(i)
    }
  }()

  func() {
    for i:=0; i < 3; i++ {
      fmt.Println(i)
    }
  }()

  elapsedTime := time.Since(start)

  fmt.Println("Total Time For Execution: " + elapsedTime.String())

  time.Sleep(time.Second)
}

И вывод программы

0
1
2
0
1
2

Далее добавляются горутины

package main

import (
    "fmt"
    "time"
)

func main() {
  start := time.Now()
  go func() {
    for i:=0; i < 3; i++ {
      fmt.Println(i)
    }
  }()

  go func() {
    for i:=0; i < 3; i++ {
      fmt.Println(i)
    }
  }()

  elapsedTime := time.Since(start)

  fmt.Println("Total Time For Execution: " + elapsedTime.String())

  time.Sleep(time.Second)
}

И вывод программы

0
1
2
0
1
2

При этом идет ускорение почти в 3 раза. Объясняется что запускается 3 внутренних "потока"

В данном сценарии в конкурентном режиме будут выполняться три потока: основной main, поток первой функции немедленного выполнения first и поток второй такой функции.

  1. В целом выглядит все довольно логично, но только я не понимаю почему вывод получился одинаковый? По логике если потоки реально выполнялись параллельно то вывод должен был бы выглядеть как 001122 разве нет?

  2. Правильно ли я понимаю что горутины в GO это больше похоже на механизм асинхронного программирования т.е. горутины выполняются последовательно но переключаются при любом i\o действии?

4
  • Ээ, измерение времени на трёх повторениях это бред какой-то
    – Alexey Ten
    11 мар 2022 в 10:16
  • Да и измерять его при использовании IO тоже весьма странно
    – Alexey Ten
    11 мар 2022 в 10:17
  • ну про время да, похоже что бред т.к. получается что когда мы делаем горутинами у нас время вычисляется сразу же т.к. основной поток идет дальше и не ждет выполнения двух функций. Но я не понимаю почему поток не прерывается на i\o и почему вывод не 001122
    – Betflop
    11 мар 2022 в 10:19
  • Сразу скажу, я совершенно не знаком с go. Из самых общих соображений очевидно, что надо копать в сторону реализации синхронизации буферизованного io в горутинах. Ускорение предположительно можно объяснить тем, что вычисление времени проходит в потоке main, совершенно независимо от действий в 2-х других потоках (либо объясните, что неявная точка join должна быть после текстуального завершения последнего блока кода, начинающегося с go func()...)
    – avp
    11 мар 2022 в 11:01

1 ответ 1

0

ускорение в 3 раза с горутинами вы получили именнно потому, что вы перестали замерять время реальной работы, которую вы эмулируете в горутинах. Дело в том что выполнение кода в горутине main не блокируется при вызове горутин. Поэтому значение переменной elapsedTime вычисляется практически сразу, не дожидаясь выполнения запущенных вами горутин. Убедиться в этом можно если вы закомментируете строчку //time.Sleep(time.Second) - в этом случае main выполнится и завершится выполнение всей программы - при этом может быть успеет что-то отработать, а может нет.

Второй момент - гарантированной полученной последовательности на самом деле не будет. Можно для наглядности немного переписать код:

package main

import (
    "fmt"
    "time"
)

func main() {
    start := time.Now()
    go func() {
        for _, i := range []string{"a", "b", "c"} {
            fmt.Println(i)
        }
    }()

    go func() {
        for _, i := range []string{"e", "f", "g"} {
            fmt.Println(i)
        }
    }()

    elapsedTime := time.Since(start)

    fmt.Println("Total Time For Execution: " + elapsedTime.String())

    time.Sleep(time.Second)
}

И его вывод будет постоянно меняться. Например пара запусков:

a
e
Total Time For Execution: 8.459µs
b
c
f
g

Total Time For Execution: 7.75µs
e
a
f
g
b
c

Вывод как раз показывает неверный момент замера времени + разная последовательность.

Чтобы измерить настоящее время исполнения - можно использовать либо каналы, либо sync.WaitGroup{}:

package main

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

func main() {
    start := time.Now()

    wg := &sync.WaitGroup{}
    wg.Add(1)
    go func() {
        for _, i := range []string{"a", "b", "c"} {
            fmt.Println(i)
        }
        wg.Done()
    }()

    wg.Add(1)
    go func() {
        for _, i := range []string{"e", "f", "g"} {
            fmt.Println(i)
        }
        wg.Done()
    }()

    wg.Wait()
    fmt.Println("Total Time For Execution: " + time.Since(start).String())
}

e
f
g
a
b
c
Total Time For Execution: 346.583µs

PS: замерять в go таким образом производительность не принято, советую почитать статью на хабре https://habr.com/ru/post/268585/ о бэнчмарках в golang

введите сюда описание изображения

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.