Metadata-Version: 2.0
Name: offspring
Version: 0.0.3
Summary: Objects and patterns for working with processes in Python using the multiprocessing library
Home-page: https://github.com/borgstrom/offspring
Author: Evan Borgstrom
Author-email: evan.borgstrom@gmail.com
License: Apache 2
Platform: UNKNOWN

Offspring
=========

.. image:: https://img.shields.io/travis/borgstrom/offspring.svg
           :target: https://travis-ci.org/borgstrom/offspring

.. image:: https://img.shields.io/codecov/c/github/borgstrom/offspring.svg
           :target: https://codecov.io/github/borgstrom/offspring

.. image:: https://img.shields.io/pypi/v/offspring.svg
           :target: https://pypi.python.org/pypi/offspring
           :alt: Latest PyPI version


This is a collection of objects and patterns for working with processes in Python using the multiprocessing library.

The main idea is that you express your unit of work as a simple method on an object and then when that object is
instantiated the work will be run in a subprocess.


Use cases
---------

Offspring was built to address the following use cases for running code in a subprocess.


Run something once
~~~~~~~~~~~~~~~~~~

.. code-block:: python

    from offspring import Subprocess


    class MyTask(Subprocess):
        def __init__(self, arg1):
            # this is run in the parent process and is used to prepare your object
            self.arg = arg
            self.start()

        def run(self):
            # this will be run in the child process and completes your work
            # ...


    MyTask('this is arg1').wait()


Run in a loop
~~~~~~~~~~~~~

.. code-block:: python

    from offspring import SubprocessLoop


    class MyTask(SubprocessLoop):
        def __init__(self, arg1):
            # this is run in the parent process and is used to prepare your object
            self.arg = arg
            self.start()

        def begin(self):
            # called at the start of the loop in your child process

        def loop(self):
            # called each loop iteration in your your child process
            # it should return a sleep duration until the next loop, or False to stop the loop

        def end(self):
            # called at the end of the loop in your child process


    MyTask('this is arg1').wait()


Implementation details
----------------------

``.process``
~~~~~~~~~~~~

Each ``Subprocess`` object has a ``.process`` attribute that is the ``multiprocessing.Process`` object.


``.start``
~~~~~~~~~~

Creates the subprocess.  If you do not customize your ``__init__`` method then you do not need to explicitly call
``.start``.  If you do remember to call ``.start`` at the end of it.


``.wait``
~~~~~~~~~

If you need to wait for your child process you can call ``.wait`` on your ``Subprocess`` object.  This is just a
shortcut to ``.join`` on the ``multiprocessing.Process`` object.


``WAIT_FOR_CHILD``
~~~~~~~~~~~~~~~~~~

Defaults to ``False``.

If set to ``True`` on your ``Subprocess`` class then a ``Pipe`` will be used to block the parent process until the child
has started.  This is useful when you want to ensure that your ``Subprocess`` object is started and ``.run`` is called
even if the parent process exits quickly.

.. code-block:: python

    class MyTask(Subprocess):
        WAIT_FOR_CHILD = True

        def run(self):
            print("This will always print")

    MyTask()

The ``SubprocessLoop`` class does this to ensure that your object has ``begin`` & ``end`` called (``loop`` may not be
called as a TERM signal received during startup will prevent the loop from every actually completing other than
``begin`` & ``end``).


``TERMINATE_ON_SHUTDOWN``
~~~~~~~~~~~~~~~~~~~~~~~~~

Defaults to ``True``.

If set to ``False`` then when ``.shutdown`` is called on a ``Subprocess`` object the child process **will not** be
terminated before being joined.  This means that the parent will block until the child completes the ``.run`` function.

.. code-block:: python

    import time

    class MyTask(Subprocess):
        TERMINATE_ON_SHUTDOWN = False

        def run(self):
            time.sleep(2)

    MyTask()


