python_prefork 0.1.1

As Parallel::Prefork, this module is intended to be some operations done in parallel.

Simple example of usage is followings

>>> from python_prefork import PythonPrefork
>>> pp = PythonPrefork()
>>> while not pp.signal_received:
>>>     if pp.start(): continue
>>>
>>>     run() # do some task in child process
>>>
>>>     pp.finish()
>>> pp.wait_all_children()

Some options can be set in constructor

[ max_workers ] maximum number of child processes to fork

[trap_signals] arrays of signals to be trapped. parent process will send these signals to all children

[on_reap_cb] function to be called when a child is end. This function must have two parameters, child pid and exit status.