code: def run(self):
          
          self.server.stats['Worker Threads'][self.getName()] = self.stats
          try:
              self.ready = True
              while True:
                  conn = self.server.requests.get()
                  if conn is _SHUTDOWNREQUEST:
                      return
  
                  self.conn = conn
                  if self.server.stats['Enabled']:
                      self.start_time = time.time()
                  try:
                      conn.communicate()
                  finally:
                      conn.close()
                      if self.server.stats['Enabled']:
                          self.requests_seen += self.conn.requests_seen
                          self.bytes_read += self.conn.rfile.bytes_read
                          self.bytes_written += self.conn.wfile.bytes_written
                          self.work_time += time.time() - self.start_time
                          self.start_time = None
                      self.conn = None
          except (KeyboardInterrupt, SystemExit) as ex:
              self.server.interrupt = ex
docs: Process incoming HTTP connections.
  
          Retrieves incoming connections from thread pool.