code: def test_asyncio_actor_with_large_concurrency(
      ray_start_regular_shared,
  ):
      @ray.remote
      class Actor:
          def sync_thread_id(self):
              time.sleep(2)
              return threading.current_thread().ident
  
          async def async_thread_id(self):
              time.sleep(2)
              return threading.current_thread().ident
  
      a = Actor.options(max_concurrency=100000).remote()
      sync_id, async_id = ray.get(
          [a.sync_thread_id.remote(), a.async_thread_id.remote()]
      )
      assert sync_id == async_id
  
imports: import asyncio
  import os
  import sys
  import threading
  import time
  import pytest
  import ray
  from ray._private.client_mode_hook import client_mode_should_convert
  from ray._private.test_utils import SignalActor, kill_actor_and_wait_for_failure, wait_for_condition, wait_for_pid_to_exit
label_desc: Use image node_id 10 for calling a global function with example usage: test_asyncio_actor_with_large_concurrency(ray_start_regular_shared) and returns: threading, threading