code: def run(self):
      try:
          with self._sock:
              self._sock.setblocking(False)
              self._run()
      finally:
          self._s1.close()
          self._s2.close()
  
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 3 for calling the TestThreadedServer obj's underlying member method code with example usage: obj.run() without return types