code: def run_coroutine_threadsafe(coro, loop):
      """Submit a coroutine object to a given event loop.
  
      Return a concurrent.futures.Future to access the result.
      """
      if not coroutines.iscoroutine(coro):
          raise TypeError("A coroutine object is required")
      future = concurrent.futures.Future()
  
      def callback():
          try:
              futures._chain_future(
                  ensure_future(coro, loop=loop), future
              )
          except (SystemExit, KeyboardInterrupt):
              raise
          except BaseException as exc:
              if future.set_running_or_notify_cancel():
                  future.set_exception(exc)
              raise
  
      loop.call_soon_threadsafe(callback)
      return future
  
imports: import concurrent.futures
  import contextvars
  import functools
  import inspect
  import itertools
  import types
  import warnings
  import weakref
  from types import GenericAlias
  from .None import base_tasks
  from .None import coroutines
  from .None import events
  from .None import exceptions
  from .None import futures
  from .coroutines import _is_coroutine
label_desc: Use image node_id 13 for calling a global function with example usage: run_coroutine_threadsafe(coro, loop) and returns: future