code: def test_multi_cli_threading(call_ray_start):
      import threading
  
      b = threading.Barrier(2)
      ret = [None, None]
  
      def get(idx):
          cli = ray.init("ray://localhost:25001", allow_multiple=True)
          with cli:
              a = ray.put(idx)
              b.wait()
              v = ray.get(a)
              assert idx == v
              b.wait()
              ret[idx] = v
  
      t1 = threading.Thread(target=get, args=(0,))
      t2 = threading.Thread(target=get, args=(1,))
      t1.start()
      t2.start()
      t1.join()
      t2.join()
      assert ret == [0, 1]
  
file_path: ray/python/ray/tests/test_client_multi.py
imports: import os
  import sys
  import pytest
  import ray
label_desc: Use image node_id 6 for calling a global function with example usage: test_multi_cli_threading(call_ray_start) without return types