الحد من تنفيذ Goroutine المتزامن
فكر في سيناريو حيث يكون لديك قائمة بعناوين URL المطلوب معالجتها وتريد تحديد عدد goroutines المتزامنة قيد التشغيل . على سبيل المثال، إذا كان لديك 30 عنوان URL، فقد تحتاج فقط إلى 10 goroutines تعمل بشكل متوازٍ.يحاول الكود المقدم استخدام قناة مخزنة مؤقتًا بالحجممتوازية للحد من عدد goroutines قيد التشغيل . ومع ذلك، لا يبدو أن هذا الأسلوب يتم حظره بعد معالجة جميع عناوين URL. الطريقة الأكثر فعالية لتحقيق هذا الحد من التزامن هي إنشاء عدد محدد من goroutines العاملة وإطعامها بعناوين URL من خلال قناة مخصصة.
إليك نسخة محسنة من الكود:parallel := flag.Int("parallel", 10, "max parallel requests allowed")
flag.Parse()
urls := flag.Args()
// Create a channel to hold URLs that workers will consume
workerURLChan := make(chan string)
// Start a goroutine to feed URLs to the workers
go func() {
for _, u := range flag.Args() {
workerURLChan في هذا الكود المحدث، نقوم بإنشاء روتين عامل لكل تنفيذ متزامن مسموح به، ويقوم هؤلاء العاملون بجلب عناوين URL من القناة المخصصة. بمجرد توزيع جميع عناوين URL، يتم إغلاق عامل URLChan، مما يؤدي إلى خروج العمال عند اكتمال عنوان URL الحالي الخاص بهم. تحد هذه الآلية بشكل فعال من عدد goroutines المتزامنة الجاري تشغيلها.
تنصل: جميع الموارد المقدمة هي جزئيًا من الإنترنت. إذا كان هناك أي انتهاك لحقوق الطبع والنشر الخاصة بك أو الحقوق والمصالح الأخرى، فيرجى توضيح الأسباب التفصيلية وتقديم دليل على حقوق الطبع والنشر أو الحقوق والمصالح ثم إرسالها إلى البريد الإلكتروني: [email protected]. سوف نتعامل مع الأمر لك في أقرب وقت ممكن.
Copyright© 2022 湘ICP备2022001581号-3