geodat.parallelprocessing

geodat.parallelprocessing.extract_output(ps, queue_output, timeout=None)[source]

Extract the output from run_in_parallel in the order when the job is declared and submitted

Return : list

geodat.parallelprocessing.put_func_to_queue(func, job_name, queue)[source]

A decorator for submitting job to queue

geodat.parallelprocessing.run_in_parallel(func)[source]

Decorator for running func in parallel Each time this decorator is called a new multiprocessing.Queue is created And the queue is to be closed by extract_output(ps,queue_output) Return: function(**kwargs) which returns (ps,queue_outout) ps is a list of Process and queue_output is a multiprocessing.Queue

Fork me on GitHub