لغة Go بالأمثلة: مجموعات الانتظار

يمكننا استخدام مجموعة انتظار لانتظار انتهاء عدة روتينات Go.

 
package main
 
import (
    "fmt"
    "sync"
    "time"
)

هذه هي الدالة التي سنشغّلها في كل روتين Go.

 
func worker(id int) {
    fmt.Printf("Worker %d starting\n", id)

انتظر لمحاكاة مهمة مكلفة.

 
    time.Sleep(time.Second)
    fmt.Printf("Worker %d done\n", id)
}
 
func main() {

تُستخدم WaitGroup هذه لانتظار انتهاء جميع روتينات Go التي بدأناها هنا. لاحظ أنه عند تمرير WaitGroup صراحة إلى الدوال، ينبغي تمريرها بالمؤشر.

 
    var wg sync.WaitGroup

ابدأ عدة روتينات Go باستخدام WaitGroup.Go.

 
    for i := 1; i <= 5; i++ {
        wg.Go(func() {
            worker(i)
        })
    }

احجب التنفيذ حتى تنتهي جميع روتينات Go التي بدأتها wg. ينتهي روتين Go عندما تعود الدالة التي يستدعيها.

 
    wg.Wait()

لاحظ أن هذا الأسلوب لا يوفر طريقة مباشرة لتمرير الأخطاء من العمال. لحالات الاستخدام الأكثر تقدمًا، فكّر في استخدام الحزمة errgroup.

 
}
 
$ go run waitgroups.go
Worker 5 starting
Worker 3 starting
Worker 4 starting
Worker 1 starting
Worker 2 starting
Worker 4 done
Worker 1 done
Worker 2 done
Worker 5 done
Worker 3 done

يُرجح أن يختلف ترتيب بدء العمال وانتهائهم مع كل تشغيل.

المثال التالي: .

إعداد Mark McGranaghan وEli Bendersky المصدر الأصلي الرخصة
الترجمة العربية بواسطة 0xKa الموقع الشخصي مصدر الترجمة