code: def _run(self):
      while self._active:
          if self._clients >= self._max_clients:
              return
  
          r, w, x = select.select(
              [self._sock, self._s1], [], [], self._timeout
          )
  
          if self._s1 in r:
              return
  
          if self._sock in r:
              try:
                  conn, addr = self._sock.accept()
              except BlockingIOError:
                  continue
              except TimeoutError:
                  if not self._active:
                      return
                  else:
                      raise
              else:
                  self._clients += 1
                  conn.settimeout(self._timeout)
                  try:
                      with conn:
                          self._handle_client(conn)
                  except Exception as ex:
                      self._active = False
                      try:
                          raise
                      finally:
                          self._test._abort_socket_test(ex)
  
imports: import asyncio
  import asyncio.events
  import contextlib
  import os
  import pprint
  import select
  import socket
  import tempfile
  import threading
  from test import support
label_desc: Use image node_id 4 for calling the TestThreadedServer obj's underlying member method code with example usage: obj._run() without return types