code: def _run(self, test_fn, rank, world_size):
      crypten.init_thread(rank, world_size)
  
      self.setUp()
  
      try:
          test_fn()
      except Exception:
          self.exception_queue.put(sys.exc_info())
  
file_path: CrypTen/test/multithread_test_case.py
imports: import queue
  import sys
  import threading
  import unittest
  from functools import wraps
  from threading import Thread
  import crypten
label_desc: Use image node_id 9 for calling the MultiThreadTestCase obj's underlying member method code with example usage: obj._run(test_fn, rank, world_size) without return types