Kaip organizuotas kanalas po gaubtu Go?

Go kanalas yra duomenų struktūra, įgyvendinta vykdymo metu, kuri užtikrina saugų duomenų perdavimą tarp gorutinių. Užkulisiuose kanalas yra eilė su blokavimu ir sinchronizacijos mechanizmais.

Pagrindiniai įgyvendinimo punktai:

• Kanalas turi buferį (jei jis yra su buferiu) arba veikia kaip sinchroninio perdavimo taškas (jei buferio nėra).
• Sinchronizacijai naudojami mutex'ai ir sąlygų kintamieji (cond variables), kad gorutinos galėtų blokuotis ir būti pažadintos siuntimo ar gavimo metu.
• Siunčiant į kanalą, jei buferis pilnas, gorutina blokuojasi, kol atsiranda laisva vieta.
• Gaunant iš kanalo, jei buferis tuščias, gorutina blokuojasi, kol pasirodys duomenys.

Supaprastintas logikos pavyzdys:

// Siunčiant į kanalą
func (ch *channel) send(value T) {
    ch.lock.Lock()
    defer ch.lock.Unlock()
    for ch.bufferFull() {
        ch.cond.Wait() // laukia, kol atsiras vietos
    }
    ch.enqueue(value)
    ch.cond.Signal() // praneša gavėjams
}

Šiuo būdu kanalas užtikrina saugų ir sinchronizuotą ryšį tarp gorutinių be aiškių užraktų naudotojo kodo lygyje.