yt.utilities.parallel_tools package

Submodules

• yt.utilities.parallel_tools.controller_system module
  • WorkSplitter
    • WorkSplitter.run()
    • WorkSplitter.run_controller()
    • WorkSplitter.run_group1()
    • WorkSplitter.run_group2()
    • WorkSplitter.setup()
• yt.utilities.parallel_tools.io_runner module
  • IOCommunicator
    • IOCommunicator.initialize_data()
    • IOCommunicator.io_iter()
    • IOCommunicator.peek()
    • IOCommunicator.preload()
    • IOCommunicator.push()
    • IOCommunicator.wait()
  • IOHandlerRemote
    • IOHandlerRemote.io_iter()
    • IOHandlerRemote.peek()
    • IOHandlerRemote.preload()
    • IOHandlerRemote.push()
    • IOHandlerRemote.terminate()
  • io_nodes()
  • remote_io()
• yt.utilities.parallel_tools.parallel_analysis_interface module
  • CommunicationSystem
    • CommunicationSystem.communicators
    • CommunicationSystem.pop()
    • CommunicationSystem.push()
    • CommunicationSystem.push_with_ids()
  • Communicator
    • Communicator.alltoallv_array()
    • Communicator.barrier()
    • Communicator.claim_object()
    • Communicator.comm
    • Communicator.do_not_claim_object()
    • Communicator.get_filename()
    • Communicator.is_mine()
    • Communicator.merge_quadtree_buffers()
    • Communicator.mpi_Request_Testall()
    • Communicator.mpi_Request_Waitall()
    • Communicator.mpi_Request_Waititer()
    • Communicator.mpi_allreduce()
    • Communicator.mpi_bcast()
    • Communicator.mpi_exit_test()
    • Communicator.mpi_info_dict()
    • Communicator.mpi_nonblocking_recv()
    • Communicator.mpi_nonblocking_send()
    • Communicator.par_combine_object()
    • Communicator.preload()
    • Communicator.probe_loop()
    • Communicator.rank
    • Communicator.recv_array()
    • Communicator.recv_quadtree()
    • Communicator.send_array()
    • Communicator.send_quadtree()
    • Communicator.size
    • Communicator.write_on_root()
  • FilterAllMessages
    • FilterAllMessages.filter()
  • GroupOwnership
    • GroupOwnership.comm
    • GroupOwnership.dec()
    • GroupOwnership.get_dependencies()
    • GroupOwnership.inc()
    • GroupOwnership.item
    • GroupOwnership.partition_index_2d()
    • GroupOwnership.partition_index_3d()
    • GroupOwnership.partition_index_3d_bisection_list()
    • GroupOwnership.partition_region_3d()
    • GroupOwnership.switch()
  • ObjectIterator
  • ParallelAnalysisInterface
    • ParallelAnalysisInterface.comm
    • ParallelAnalysisInterface.get_dependencies()
    • ParallelAnalysisInterface.partition_index_2d()
    • ParallelAnalysisInterface.partition_index_3d()
    • ParallelAnalysisInterface.partition_index_3d_bisection_list()
    • ParallelAnalysisInterface.partition_region_3d()
  • ParallelDummy
    • ParallelDummy.mro()
  • ParallelObjectIterator
  • ProcessorPool
    • ProcessorPool.add_workgroup()
    • ProcessorPool.available_ranks
    • ProcessorPool.comm
    • ProcessorPool.free_all()
    • ProcessorPool.free_workgroup()
    • ProcessorPool.from_sizes()
    • ProcessorPool.ranks
    • ProcessorPool.size
    • ProcessorPool.tasks
  • ResultsStorage
    • ResultsStorage.result
    • ResultsStorage.result_id
    • ResultsStorage.slots
  • Workgroup
  • default_mpi_excepthook()
  • enable_parallelism()
  • get_mpi_type()
  • parallel_blocking_call()
  • parallel_objects()
  • parallel_passthrough()
  • parallel_ring()
  • parallel_root_only()
  • parallel_root_only_then_broadcast()
  • parallel_simple_proxy()
  • traceback_writer_hook()
• yt.utilities.parallel_tools.task_queue module
  • TaskQueueNonRoot
    • TaskQueueNonRoot.finalize()
    • TaskQueueNonRoot.next()
    • TaskQueueNonRoot.run()
    • TaskQueueNonRoot.send_result()
  • TaskQueueRoot
    • TaskQueueRoot.assign_task()
    • TaskQueueRoot.finalize()
    • TaskQueueRoot.handle_assignment()
    • TaskQueueRoot.insert_result()
    • TaskQueueRoot.next()
    • TaskQueueRoot.run()
    • TaskQueueRoot.send_result()
  • dynamic_parallel_objects()
  • task_queue()

Module contents

Tools for parallelism.