Hogyan szervezzük meg az interakciót és az adatok átadását a rendszeren belül a csatornákon keresztül?

A Go nyelvben a goroutine-ok közötti interakció gyakran csatornákon (channels) keresztül szerveződik — típusos csővezetékek az adatok továbbítására.

Az adatok továbbításához egy csatornát hozunk létre make(chan Típus) segítségével. A goroutine-ok az <- operátorral küldhetnek adatokat a csatornára, és ugyanazzal az operátorral vehetnek is adatokat a csatornáról, ez biztosítja a szinkronizációt.

Példa:

package main

import (
    "fmt"
    "time"
)

func gyarto(ch chan<- int) {
    for i := 0; i < 5; i++ {
        ch <- i // adatok küldése
        time.Sleep(time.Millisecond * 500)
    }
    close(ch) // lezárjuk a csatornát, jelezve a végét
}

func fogyaszto(ch <-chan int) {
    for val := range ch { // adatok fogadása a csatornáról
        fmt.Println("Kapott:", val)
    }
}

func main() {
    ch := make(chan int)
    go gyarto(ch)
    fogyaszto(ch)
}

Így a csatornák biztonságosan és hatékonyan teszik lehetővé az adatok továbbítását goroutine-ok között, elkerülve a versenyhelyzeteket és a blokkolásokat.