class_docstr: Concurrent event loop context.
  
  Args:
      concurrency: max processing concurrency.
code: def _run_loop(self):
      self._loop.run_forever()
  
file_path: pytorch_geometric/torch_geometric/distributed/event_loop.py
imports: import asyncio
  import atexit
  import logging
  from threading import BoundedSemaphore, Thread
  from typing import Callable, Optional
  import torch
label_desc: Use image node_id 6 for calling the ConcurrentEventLoop obj's underlying member method code with example usage: obj._run_loop() without return types