Jak w języku Go realizowany jest model pracy z konkurencyjnością i synchronizacją?

W języku Go współbieżność jest realizowana za pomocą lekkich wątków zwanych goroutines. Goroutines uruchamia się za pomocą słowa kluczowego go i działają one równolegle, przy czym runtime Go sam zarządza ich planowaniem.

Do synchronizacji i wymiany danych między goroutines używa się kilku mechanizmów:

• Kanały (channels) — umożliwiają bezpieczne przesyłanie danych między goroutines, zapewniając synchronizację. Kanały można porównać do kolejek, które blokują nadawcę, jeśli kanał jest pełny, i odbiorcę, jeśli jest pusty.

• Pakiet sync — zawiera prymitywy synchronizacji, takie jak mutexy (sync.Mutex), zmienne warunkowe (sync.Cond), grupy oczekiwania (sync.WaitGroup) i inne.

Przykład użycia goroutines i kanałów:

package main
import (
    "fmt"
    "time"
)

func worker(id int, ch chan string) {
    time.Sleep(time.Second)
    ch <- fmt.Sprintf("Pracownik %d zakończony", id)
}

func main() {
    ch := make(chan string)
    for i := 1; i <= 3; i++ {
        go worker(i, ch)
    }
    for i := 1; i <= 3; i++ {
        msg := <-ch
        fmt.Println(msg)
    }
}

Tutaj trzy goroutines działają równolegle, a kanał służy do odbioru wyników od każdej z nich.