قوائم المهام في Go: دليل شامل للمبتدئين

مقدمة في قوائم المهام بلغة Go

قوائم المهام (task queues) هي أحد الأنماط الأساسية في تطوير التطبيقات عالية التحميل. فهي تسمح بتنظيم المعالجة غير المتزامنة للبيانات، وتوزيع الحمل، وزيادة تحمل الأخطاء في النظام. في لغة Go، بفضل الآليات المدمجة للتوازي - goroutines والقنوات - يصبح تنفيذ قوائم المهام أنيقًا وفعالًا بشكل لا يصدق.

في هذه المقالة، سنشرح كيفية إنشاء قوائم المهام في Go من الصفر. ستتعرف على ما هي goroutines والقنوات، وكيفية تنظيم مجموعة من العمال (worker pool) ومعالجة المهام بالتوازي. المادة موجهة للمطورين المبتدئين الذين لديهم معرفة بأساسيات بناء جملة Go.

الأساسيات: goroutines والقنوات

قبل الانتقال إلى قوائم المهام، من المهم فهم مفهومين أساسيين في Go:

\n
• Goroutine — خيط تنفيذ خفيف الوزن. يتم تشغيله باستخدام الكلمة المفتاحية go قبل استدعاء الدالة.
\n
• قناة (channel) — "قناة" محددة النوع لنقل البيانات بين goroutines. تسمح بمزامنة عملها.
\n

مثال على أبسط goroutine وقناة:

package main\n\nimport "fmt"\n\nfunc main() {\n    ch := make(chan string)\n\n    go func() {\n        ch <- "مرحبًا من goroutine!"\n    }()\n\n    msg := <-ch\n    fmt.Println(msg)\n}\n

في هذا المثال، أنشأنا قناة ch، وقمنا بتشغيل goroutine مجهولة ترسل رسالة إليها، ثم استقبلت goroutine الرئيسية هذه الرسالة. على هذه الآلية تُبنى قوائم المهام.

تنفيذ قائمة مهام بسيطة

أبسط قائمة مهام هي قناة نضع فيها المهام، وواحدة أو أكثر من goroutines تقوم بمعالجتها. لنلقِ نظرة على مثال أساسي:

package main\n\nimport (\n    "fmt"\n    "time"\n)\n\nfunc worker(id int, tasks <-chan int) {\n    for task := range tasks {\n        fmt.Printf("العامل %d بدأ المهمة %d\\n", id, task)\n        time.Sleep(time.Second) // محاكاة العمل\n        fmt.Printf("العامل %d أكمل المهمة %d\\n", id, task)\n    }\n}\n\nfunc main() {\n    tasks := make(chan int, 10) // قناة مخزنة مؤقتًا\n\n    // تشغيل عامل واحد\n    go worker(1, tasks)\n\n    // إرسال 5 مهام\n    for i := 1; i <= 5; i++ {\n        tasks <- i\n    }\n\n    close(tasks) // إغلاق القناة\n    time.Sleep(2 * time.Second) // إعطاء وقت للمعالجة\n}\n

هنا worker هي دالة تقرأ من القناة tasks. القناة مخزنة مؤقتًا (سعة 10)، لذا يمكننا إرسال عدة مهام دون حظر. بعد إغلاق القناة، ستنتهي حلقة for range تلقائيًا.

لاحظ: استخدمنا <-chan int - وهي قناة للقراءة فقط. هذه ممارسة جيدة توضح بوضوح أن العامل لا يجب أن يرسل بيانات إلى هذه القناة.

القنوات المخزنة مؤقتًا وغير المخزنة

في المثال أعلاه، استخدمنا قناة مخزنة مؤقتًا (make(chan int, 10)). الفرق بين أنواع القنوات:

\n
• قناة غير مخزنة — يتم حظر الإرسال حتى يقرأ المستقبل البيانات. مثالية للمزامنة.
\n
• قناة مخزنة مؤقتًا — يتم حظر الإرسال فقط عندما يكون المخزن ممتلئًا. تسمح بتجميع المهام وتقليل التأخير.
\n

لقوائم المهام، عادةً ما تُستخدم القنوات المخزنة مؤقتًا حتى يتمكن المنتج من إرسال المهمة بسرعة ومواصلة العمل دون انتظار تنفيذها.

مجموعة العمال (Worker Pool) في Go

عامل واحد جيد، لكن عدة عمال أفضل. مجموعة العمال تسمح بمعالجة المهام بالتوازي باستخدام جميع نوى المعالج. إليك كيفية تنفيذ ذلك:

package main\n\nimport (\n    "fmt"\n    "sync"\n    "time"\n)\n\nfunc worker(id int, tasks <-chan int, wg *sync.WaitGroup) {\n    defer wg.Done()\n    fo