code: def test_queue_set_delete_existing_queue_threading(
      root_verify_key,
      queue: Any,
  ) -> None:
      thread_cnt = 3
      repeats = REPEATS
  
      execution_err = None
      objs = []
  
      for _ in range(repeats * thread_cnt):
          obj = mock_queue_object()
          res = queue.set(root_verify_key, obj, ignore_duplicates=False)
          objs.append(obj)
  
          assert res.is_ok()
  
      def _kv_cbk(tid: int) -> None:
          nonlocal execution_err
          for idx in range(repeats):
              item_idx = tid * repeats + idx
  
              for _ in range(10):
                  res = queue.find_and_delete(
                      root_verify_key, id=objs[item_idx].id
                  )
                  if res.is_ok():
                      break
  
              if res.is_err():
                  execution_err = res
              assert res.is_ok()
  
      tids = []
      for tid in range(thread_cnt):
          thread = Thread(target=_kv_cbk, args=(tid,))
          thread.start()
  
          tids.append(thread)
  
      for thread in tids:
          thread.join()
  
      assert execution_err is None
      assert len(queue) == 0
  
imports: import sys
  from threading import Thread
  from typing import Any
  from joblib import Parallel
  from joblib import delayed
  import pytest
  from syft.service.queue.queue_stash import QueueItem
  from syft.service.worker.worker_pool import WorkerPool
  from syft.service.worker.worker_pool_service import SyftWorkerPoolService
  from syft.store.linked_obj import LinkedObject
  from syft.types.uid import UID
  from .store_fixtures_test import mongo_queue_stash_fn
  from .store_fixtures_test import sqlite_queue_stash_fn
label_desc: Use image node_id 7 for calling a global function with example usage: test_queue_set_delete_existing_queue_threading(root_verify_key, queue) without return types