Sonuç toplama

Sonuçları ayrı bir channel'dan toplarsın.

Sonuçları toplamak

Sonuç sayısı her zaman bilinmez. Daha sağlam yol: işçileri sync.WaitGroup ile izlemek ve hepsi bitince sonuç kanalını kapatmak. Böylece toplayan taraf range kullanabilir:

var wg sync.WaitGroup
for w := 0; w < n; w++ {
    wg.Add(1)
    go func() { defer wg.Done(); isci(isler, sonuclar) }()
}
go func() { wg.Wait(); close(sonuclar) }()

for s := range sonuclar { ... }

Sıra ve eşleme

Eşzamanlı işçilerden sonuçlar rastgele sırayla gelir. Girdi sırası önemliyse ya sonucu iş kimliğiyle birlikte gönderip bir dilimde o kimliğin yerine yazarsın ya da sonuçları sonradan sıralarsın:

out := make([]int64, len(dosyalar))
for s := range sonuclar {
    out[s.IsID] = s.Boyut
}

Uygulama Sıralı toplama

Dört işin (ID 0–3) her biri ID * 10 değerini üretsin. İki işçi kullan, WaitGroup ile bitişi izle, sonuç kanalını kapat ve sonuçları ID sırasına göre bir dilime yaz. Dilimi yazdır.

Örnek çözümü göster

package main

import (
    "fmt"
    "sync"
)

type Sonuc struct{ ID, Deger int }

func main() {
    isler := make(chan int)
    sonuclar := make(chan Sonuc)
    var wg sync.WaitGroup
    for w := 0; w < 2; w++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            for id := range isler {
                sonuclar <- Sonuc{id, id * 10}
            }
        }()
    }
    go func() {
        for i := 0; i < 4; i++ {
            isler <- i
        }
        close(isler)
    }()
    go func() {
        wg.Wait()
        close(sonuclar)
    }()
    out := make([]int, 4)
    for s := range sonuclar {
        out[s.ID] = s.Deger
    }
    fmt.Println(out)
}

Kendini test et

<code>wg.Add(1)</code> neden goroutine'in <strong>içinde</strong> değil, önünde çağrılır?
- Done'u otomatik çağırsın diye
- Wait, Add'den önce çalışıp erken dönmesin diye
- Daha kısa olduğu için
- Add goroutine içinde çalışmaz
Cevabı göster

Wait, Add'den önce çalışıp erken dönmesin diye — Goroutine henüz başlamadan Wait çalışırsa sayaç sıfır görünür ve Wait hemen döner; Add önceden yapılmalıdır.

Hepsini bekle

go func() {
    wg.____()
    close(sonuclar)
}()

Cevabı göster

go func() {
    wg.Wait()
    close(sonuclar)
}()

Araç

wg.Add(1)

Goroutine'den önce
defer wg.Done()

İşçi bitince
wg.Wait + close

Sonuç kanalını kapat
out[s.IsID]

Girdi sırasını koru

Sıradaki ders: Hata yönetimi

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler