parameters: (self, func, iterable, chunksize=None, callback=None)
return_statement: return result
docstring: Asynchronous equivalent of `map()` builtin
docstring_summary: Asynchronous equivalent of `map()` builtin
docstring_tokens: Asynchronous equivalent of map () builtin
function: def map_async(self, func, iterable, chunksize=None, callback=None):
          '''
          Asynchronous equivalent of `map()` builtin
          '''
          assert self._state == RUN
          if not hasattr(iterable, '__len__'):
              iterable = list(iterable)
  
          if chunksize is None:
              chunksize, extra = divmod(len(iterable), len(self._pool) * 4)
              if extra:
                  chunksize += 1
          if len(iterable) == 0:
              chunksize = 0
  
          task_batches = Pool._get_tasks(func, iterable, chunksize)
          result = MapResult(self._cache, chunksize, len(iterable), callback)
          self._taskqueue.put((((result._job, i, mapstar, (x,), {})
                                for i, x in enumerate(task_batches)), None))
          return result
function_tokens: def map_async ( self , func , iterable , chunksize = None , callback = None ) : assert self . _state == RUN if not hasattr ( iterable , '__len__' ) : iterable = list ( iterable ) if chunksize is None : chunksize , extra = divmod ( len ( iterable ) , len ( self . _pool ) * 4 ) if extra : chunksize += 1 if len ( iterable ) == 0 : chunksize = 0 task_batches = Pool . _get_tasks ( func , iterable , chunksize ) result = MapResult ( self . _cache , chunksize , len ( iterable ) , callback ) self . _taskqueue . put ( ( ( ( result . _job , i , mapstar , ( x , ) , { } ) for i , x in enumerate ( task_batches ) ) , None ) ) return result