code: def test_thread_name():
      with ThreadPoolExecutor(2) as e:
          e.map(id, range(10))
          assert len({thread.name for thread in e._threads}) == 2
  
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 8 for calling a global function with example usage: test_thread_name() without return types