code: def test_shutdown_wait():
      e = ThreadPoolExecutor(1)
      future = e.submit(sleep, 1)
      sleep(0.01)
  
      start = time()
      e.shutdown(wait=False)
      end = time()
      assert end - start < 1
  
file_path: distributed/distributed/tests/test_threadpoolexecutor.py
imports: from __future__ import annotations
  import threading
  from time import sleep
  from distributed.metrics import time
  from distributed.threadpoolexecutor import ThreadPoolExecutor, rejoin, secede
label_desc: Use image node_id 4 for calling a global function with example usage: test_shutdown_wait() without return types