shaclapi.multiprocessing package

Subpackages

• shaclapi.multiprocessing.Xgjoin package
  • Submodules
    • shaclapi.multiprocessing.Xgjoin.OperatorStructures module
      • Record
      • RJTTail
      • FileDescriptor
    • shaclapi.multiprocessing.Xgjoin.Xgjoin module
      • Xgjoin
  • Module contents
• shaclapi.multiprocessing.Xgoptional package
  • Submodules
    • shaclapi.multiprocessing.Xgoptional.OperatorStructures module
      • Record
      • RJTTail
      • FileDescriptor
    • shaclapi.multiprocessing.Xgoptional.Xgoptional module
      • Xgoptional
  • Module contents

Submodules

• shaclapi.multiprocessing.PipeAdapter module
  • ConnectionAdapter
    • ConnectionAdapter.put()
    • ConnectionAdapter.get()
  • PipeAdapter
  • QueueAdapter
• shaclapi.multiprocessing.ThreadEx module
  • ThreadEx
    • ThreadEx.join()
    • ThreadEx.run()
• shaclapi.multiprocessing.contactSource module
  • contactSource()
  • contactSourceAux()
• shaclapi.multiprocessing.functions module
  • ValReport
    • ValReport.SHAPE
    • ValReport.IS_VALID
    • ValReport.REASON
  • mp_post_processing()
  • mp_validate()
  • mp_xjoin()
  • mp_output_completion()
• shaclapi.multiprocessing.runner module
  • Runner
    • Runner.start_process()
    • Runner.stop_process()
    • Runner.get_new_queue()
    • Runner.get_new_out_queues()
    • Runner.new_task()
  • mp_function()

Module contents