class_docstr: MPI-based asynchronous executor.
class_docstr_tok: ["MPI-based","asynchronous","executor","."]
docstr: Return an iterator equivalent to ``itertools.starmap(...)``.
  
  Args:
      fn: A callable that will take positional argument from iterable.
      iterable: An iterable yielding ``args`` tuples to be used as
          positional arguments to call ``fn(*args)``.
      timeout: The maximum number of seconds to wait. If ``None``, then
          there is no limit on the wait time.
      chunksize: The size of the chunks the iterable will be broken into
          before being passed to a worker process.
      unordered: If ``True``, yield results out-of-order, as completed.
  
  Returns:
      An iterator equivalent to ``itertools.starmap(fn, iterable)``
      but the calls may be evaluated out-of-order.
  
  Raises:
      TimeoutError: If the entire result iterator could not be generated
          before the given timeout.
      Exception: If ``fn(*args)`` raises for any values.
docstr_tok: ["Return","an","iterator","equivalent","to","``","itertools.starmap","(","...",")","``",".","Args",":","fn",":","A","callable","that","will","take","positional","argument","from","iterable",".","iterable",":","An","iterable","yielding","``","args","``","tuples","to","be","used","as","positional","arguments","to","call","``","fn","(","*","args",")","``",".","timeout",":","The","maximum","number","of","seconds","to","wait",".","If","``","None","``",",","then","there","is","no","limit","on","the","wait","time",".","chunksize",":","The","size","of","the","chunks","the","iterable","will","be","broken","into","before","being","passed","to","a","worker","process",".","unordered",":","If","``","True","``",",","yield","results","out-of-order",",","as","completed",".","Returns",":","An","iterator","equivalent","to","``","itertools.starmap","(","fn",",","iterable",")","``","but","the","calls","may","be","evaluated","out-of-order",".","Raises",":","TimeoutError",":","If","the","entire","result","iterator","could","not","be","generated","before","the","given","timeout",".","Exception",":","If","``","fn","(","*","args",")","``","raises","for","any","values","."]
code: def starmap(
      self, fn, iterable, timeout=None, chunksize=1, unordered=False
  ):
      """Return an iterator equivalent to ``itertools.starmap(...)``.
  
      Args:
          fn: A callable that will take positional argument from iterable.
          iterable: An iterable yielding ``args`` tuples to be used as
              positional arguments to call ``fn(*args)``.
          timeout: The maximum number of seconds to wait. If ``None``, then
              there is no limit on the wait time.
          chunksize: The size of the chunks the iterable will be broken into
              before being passed to a worker process.
          unordered: If ``True``, yield results out-of-order, as completed.
  
      Returns:
          An iterator equivalent to ``itertools.starmap(fn, iterable)``
          but the calls may be evaluated out-of-order.
  
      Raises:
          TimeoutError: If the entire result iterator could not be generated
              before the given timeout.
          Exception: If ``fn(*args)`` raises for any values.
  
      """  # noqa: D402
      # pylint: disable=too-many-arguments
      if chunksize < 1:
          raise ValueError("chunksize must be >= 1.")
      if chunksize == 1:
          return _starmap_helper(
              self.submit, fn, iterable, timeout, unordered
          )
      else:
          return _starmap_chunks(
              self.submit, fn, iterable, timeout, unordered, chunksize
          )
  
imports: import sys
  import time
  import functools
  import itertools
  import threading
  from ._base import Future
  from ._base import Executor
  from ._base import as_completed
  from .None import _core
label_desc: Use image node_id 8 for calling the MPIPoolExecutor obj's underlying member method code with example usage: obj.starmap(fn, iterable, timeout, chunksize, unordered) and returns: _starmap_helper, _starmap_chunks