إدارة الاتصالات غير القابلة للتوقف في Python

بدأنا هنا بالتحدث عن تجربتك مع استخدام multiprocessing.connection.Listener في تبادل البيانات بين العمليات، حيث أشرت إلى كيفية عمله بشكل سلس بالنسبة لك. ومن ثم ذكرت تحدي الذي تواجهه حاليًا وهو أن listener.accept() يقفل تنفيذ البرنامج حتى يتم تأسيس اتصال من عميل. تساءلت عن وجود طريقة بسيطة لإدارة التحقق غير القابل للتوقف لـ multiprocessing.connection أو هل يجب عليك استخدام خيط مخصص لهذا الغرض؟

للتعامل مع هذه المشكلة، يمكنك استخدام ميزة المهلة (Timeout) في Listener بحيث يتم تحديد مدة زمنية قبل أن يتم إعادة التنفيذ في حالة عدم تأسيس الاتصال. هذا سيمكنك من إدراج أنشطة أخرى في الـ mainloop الخاص بك بين فحص الاتصالات.

إليك كيف يمكن تطبيق هذه الفكرة في الشفرة:

python
from multiprocessing.connection import Listener
import select

def mainloop():
    listener = Listener(address=('localhost', 6000), authkey=b'secret')
    listener._listener.setblocking(False)  # Set the listener socket to non-blocking

    while True:
        # Use select to wait for connections with timeout
        ready = select.select([listener._listener], [], [], 0.1)  # Timeout of 0.1 seconds
        if ready[0]:  # If there's a connection
            conn = listener.accept()
            msg = conn.recv() 
            print('got message: %r' % msg)
            conn.close()
        else:
            # Do something else while waiting for connections
            print("Waiting for connection...")

if __name__ == "__main__":
    mainloop()

قمت بإضافة listener._listener.setblocking(False) لتعيين مؤشر الاستماع إلى غير القابل للتوقف. ثم استخدمت select للانتظار عندما يكون هناك اتصالات جاهزة للاستقبال، مع تحديد فترة زمنية معينة (0.1 ثانية في هذا المثال). وإذا كان هناك اتصال جاهز، ستستمر العملية في استقبال الرسائل كالمعتاد، وإلا فستقوم بأداء أنشطة أخرى داخل الحلقة الرئيسية.

بهذه الطريقة، يمكنك تجنب حدوث انتظار مزمن وتمكين وظائف أخرى للقيام بها خلال الانتظار على الاتصالات.

المزيد من المعلومات

Node.js لتطبيقات الشركات: التحديات والإمكانيات

تحويل ألوان الصور في تطوير الويب