SerialNonParallelizer

Totally serial evaluation for cases where no parallelism is provide

 

get_nprocs(self): 

 

get_id(self): 

 

initialize(self): 

Initializes a parallelizer if necessary

  • :returns: _

 

finalize(self, exc_type, exc_val, exc_tb): 

Finalizes a parallelizer (if necessary) if necessary

  • :returns: _

 

@property
on_main(self): 

Returns whether or not the executing process is the main process or not

  • :returns: _

 

send(self, data, loc, **kwargs): 

A no-op

  • data: Any
  • kwargs: Any
  • :returns: _

 

receive(self, data, loc, **kwargs): 

A no-op

  • data: Any
  • kwargs: Any
  • :returns: _

 

broadcast(self, data, **kwargs): 

A no-op

  • data: Any
  • kwargs: Any
  • :returns: _

 

scatter(self, data, **kwargs): 

A no-op

  • data: Any
  • kwargs: Any
  • :returns: _

 

gather(self, data, **kwargs): 

A no-op

  • data: Any
  • kwargs: Any
  • :returns: _

 

map(self, function, data, extra_args=None, extra_kwargs=None, **kwargs): 

Performs a serial map of the function over the passed data

  • function: Any
  • data: Any
  • kwargs: Any
  • :returns: _

 

starmap(self, function, data, extra_args=None, extra_kwargs=None, **kwargs): 

Performs a serial map with unpacking of the function over the passed data

  • function: Any
  • data: Any
  • kwargs: Any
  • :returns: _

 

apply(self, func, *args, comm=None, main_kwargs=None, **kwargs): 

 

wait(self): 

No need to wait when you’re in a serial environment

  • :returns: _

Feedback

Examples

Templates

Documentation