Added timeout loop

Author: prithviraj-chaudhuri

Lib/multiprocessing/connection.py

@@ -470,6 +470,7 @@ class Listener(object):
     connections, or for a Windows named pipe.
     '''
     def __init__(self, address=None, family=None, backlog=1, authkey=None):
+
         family = family or (address and address_type(address)) \
                  or default_family
         address = address or arbitrary_address(family)
@@ -485,6 +486,10 @@ def __init__(self, address=None, family=None, backlog=1, authkey=None):
 
         self._authkey = authkey
 
+    def settimeout(self, timeout):
+        if timeout:
+            self._listener.settimeout(timeout)
+
     def accept(self):
         '''
         Accept a connection on the bound socket or named pipe of `self`.
@@ -639,6 +644,9 @@ def __init__(self, address, family, backlog=1):
         else:
             self._unlink = None
 
+    def settimeout(self, timeout):
+        self._socket.settimeout(timeout)
+
     def accept(self):
         s, self._last_accepted = self._socket.accept()
         s.setblocking(True)
@@ -697,6 +705,9 @@ def _new_handle(self, first=False):
                 _winapi.NMPWAIT_WAIT_FOREVER, _winapi.NULL
                 )
 
+        def settimeout(self, timeout):
+            pass
+
         def accept(self):
             self._handle_queue.append(self._new_handle())
             handle = self._handle_queue.pop(0)

Lib/multiprocessing/managers.py

@@ -191,12 +191,15 @@ def serve_forever(self):
     def accepter(self):
         while True:
             try:
+                self.listener.settimeout(20)
                 c = self.listener.accept()
             except OSError:
                 continue
             t = threading.Thread(target=self.handle_request, args=(c,))
             t.daemon = True
             t.start()
+            if self.stop_event.is_set():
+                break
 
     def _handle_request(self, c):
         request = None