Как сделать синхронизацию рутин в golang?

Question

[Alexey Ulianov]

for results.Next() {
var amx Amx_servers
// for each row, scan the result into our tag composite object
err = results.Scan(&amx.Id, &amx.Serverip, &amx.Serverport)
if err != nil {
amx.Serverport = 0
}
//fmt.Println(amx.Serverip, amx.Serverport)
go gol(amx.Serverip, amx.Serverport, amx.Id)

//fmt.Println(amx.Id)

}

В цикле вызываю функцию gol через рутину go.
Цикл выводит 10000 записей. Выводит он их за пару секунд.
А вот функции gol нужно проделать некоторые действия. Подключиться к серверу, получить инфу. Плюс если сервер не отвечает, тайм аут 3 сек. Вообщем выполняется не все из списка.
Так вот, как реализовать синхронизацию, что бы пока все рутины не завершились, функция не закрывалась или как правильно не прекращала работу, поправьте если не так выразился. Я новичок в GO

Answer 1

[uvelichitel]

sync.WaitGroup из stdlib

func WaitForWorkers(){
    var wg sync.WaitGroup
    for range{
        ...
        wg.Add(1)
        go gol(...)
    }
    wg.Wait()
}
func gol(...){
    ...
    wg.Done()
}

Comments

[Alexey Ulianov]

Благодарю. Все получилось) Спасибо огромное)

Answer 2

[Vladislav Vlastovskiy]

https://golang.org/pkg/sync/#example_WaitGroup

Comments

[Alexey Ulianov]

Спасибо огромное. Ознакомлюсь обязательно ))