yt.utilities.parallel_tools.task_queue module¶
- class yt.utilities.parallel_tools.task_queue.TaskQueueNonRoot(tasks, comm, subcomm)[source]¶
Bases:
object
- next()¶
- class yt.utilities.parallel_tools.task_queue.TaskQueueRoot(tasks, comm, njobs)[source]¶
Bases:
TaskQueueNonRoot
- finalize(vals=None)¶
- next()¶
- send_result(result)¶