Python Hints

Python Hints

اینم براساس راهکار کسی که استخدام شد؛ استفاده از multiprocessing.Value برای اینکه بتونه بین پراسس‌ها وضعیت رو بررسی کنه؛ به محض اینکه یکی از پراسس‌ها اعلام کنه به جواب رسیده found.value باقی پراسس‌ها قطع می‌شند و پردازش تکمیل میشه. با این روش؛ جواب هش اول…

یه کار خوب دیگم که میشه کرد استفاده از concurrent.futures هست به نظر من. interface راحتی در اختیار میذاره برای حل کردن این موضوع. میشه یه process pool ساخت، تسک ها رو submit کرد و بعد wait کرد روی future ها. منتها با return_when عه FIRST_COMPLETE. اولی که اومد باقی kill بشن. برای مواقعی که نیاز نداریم gracefully تسک ها رو shutdown بکنیم (مثل اینجا) این جواب میده.
حالا من انتظار داشتم که متد shutdown یه argument ای چیزی تحت عنوان force میگرفت من مجبور نشم process ها رو اونطوری بگیرم و کیل کنم. ولی بازم خونه api تمیزی داره این.

پ.ن:
یک راهکار خوب از سروش؛ منم توضیحاتم رو همینجا می‌نویسم.

توی راه‌حل اول گفتم نتایج بهتری می‌شه داشت؛ مشکل راه‌حل این بود که فرقی نمی‌کرد کی به جواب برسیم باید برای همه صبر می‌کردیم.
اما یک کار خوب کرده بودیم؛ استفاده از ProcessPool و عدم نیاز به SharedMemory و انتقال مقدار اون‌ بین پروسس‌ها (اینکار سربار زیادی داره)

ادامه پست بعدی ....

❤13👍5

www.tgoop.com/pyHints/876

4.99K viewsedited  Aug 6 at 20:58

یه کار خوب دیگم که میشه کرد استفاده از concurrent.futures هست به نظر من. interface راحتی در اختیار میذاره برای حل کردن این موضوع. میشه یه process pool ساخت، تسک ها رو submit کرد و بعد wait کرد روی future ها. منتها با return_when عه FIRST_COMPLETE. اولی که اومد باقی kill بشن. برای مواقعی که نیاز نداریم gracefully تسک ها رو shutdown بکنیم (مثل اینجا) این جواب میده.
حالا من انتظار داشتم که متد shutdown یه argument ای چیزی تحت عنوان force میگرفت من مجبور نشم process ها رو اونطوری بگیرم و کیل کنم. ولی بازم خونه api تمیزی داره این.

BY Python Hints