class_docstr: Vectorized environment that runs multiple environments in parallel.
  
  It uses ``multiprocessing`` processes, and pipes for communication.
  
  Example::
  
      >>> import gym
      >>> env = gym.vector.AsyncVectorEnv([
      ...     lambda: gym.make("Pendulum-v0", g=9.81),
      ...     lambda: gym.make("Pendulum-v0", g=1.62)
      ... ])
      >>> env.reset()
      array([[-0.8286432 ,  0.5597771 ,  0.90249056],
             [-0.85009176,  0.5266346 ,  0.60007906]], dtype=float32)
class_docstr_tok: ["Vectorized","environment","that","runs","multiple","environments","in","parallel",".","It","uses","``","multiprocessing","``","processes",",","and","pipes","for","communication",".","Example",":",":",">",">",">","import","gym",">",">",">","env","=","gym.vector.AsyncVectorEnv","(","[","...","lambda",":","gym.make","(","``","Pendulum-v0","''",",","g=9.81",")",",","...","lambda",":","gym.make","(","``","Pendulum-v0","''",",","g=1.62",")","...","]",")",">",">",">","env.reset","(",")","array","(","[","[","-0.8286432",",","0.5597771",",","0.90249056","]",",","[","-0.85009176",",","0.5266346",",","0.60007906","]","]",",","dtype=float32",")"]
docstr: Calls the method with name asynchronously and apply args and kwargs to the method.
  
  Args:
      name: Name of the method or property to call.
      *args: Arguments to apply to the method call.
      **kwargs: Keyword arguments to apply to the method call.
  
  Raises:
      ClosedEnvironmentError: If the environment was closed (if :meth:`close` was previously called).
      AlreadyPendingCallError: Calling `call_async` while waiting for a pending call to complete
docstr_tok: ["Calls","the","method","with","name","asynchronously","and","apply","args","and","kwargs","to","the","method",".","Args",":","name",":","Name","of","the","method","or","property","to","call",".","*","args",":","Arguments","to","apply","to","the","method","call",".","*","*","kwargs",":","Keyword","arguments","to","apply","to","the","method","call",".","Raises",":","ClosedEnvironmentError",":","If","the","environment","was","closed","(","if",":","meth",":","`","close","`","was","previously","called",")",".","AlreadyPendingCallError",":","Calling","`","call_async","`","while","waiting","for","a","pending","call","to","complete"]
code: def call_async(self, name: str, *args, **kwargs):
      """Calls the method with name asynchronously and apply args and kwargs to the method.
  
      Args:
          name: Name of the method or property to call.
          *args: Arguments to apply to the method call.
          **kwargs: Keyword arguments to apply to the method call.
  
      Raises:
          ClosedEnvironmentError: If the environment was closed (if :meth:`close` was previously called).
          AlreadyPendingCallError: Calling `call_async` while waiting for a pending call to complete
      """
      self._assert_is_running()
      if self._state != AsyncState.DEFAULT:
          raise AlreadyPendingCallError(
              "Calling `call_async` while waiting "
              f"for a pending call to `{self._state.value}` to complete.",
              self._state.value,
          )
  
      for pipe in self.parent_pipes:
          pipe.send(("_call", (name, args, kwargs)))
      self._state = AsyncState.WAITING_CALL
  
imports: import multiprocessing
  import sys
  import time
  from copy import deepcopy
  from enum import Enum
  from typing import List, Optional, Sequence, Tuple, Union
  import numpy
  import gym
  from gym import logger
  from gym.core import ObsType
  from gym.error import AlreadyPendingCallError, ClosedEnvironmentError, CustomSpaceError, NoAsyncCallError
  from gym.vector.utils import CloudpickleWrapper, clear_mpi_env_vars, concatenate, create_empty_array, create_shared_memory, iterate, read_from_shared_memory, write_to_shared_memory
  from gym.vector.vector_env import VectorEnv
label_desc: Use image node_id 6 for calling the AsyncVectorEnv obj's underlying member method code with example usage: obj.call_async(name) without return types