Quick Python concurrent multiprocessing.Process example

mysleepypool.py

#!/usr/bin/env python
from multiprocessing import Process
import sys
from time import sleep


POLL_DURATION = 0.01


def worker(sleeptime, message):
    """Sleep for sleep time and print message."""
    sleep(sleeptime)
    sys.stdout.write('%s\n' % message)


def main():
    """Control."""
    procs = {}
    for sleeptime, message in (
            (11.0, 'Hello World 11!'),
            (13.0, 'Hello World 13!'),
            (10.0, 'Hello World 10!'),
            (9.0, 'Hello World 9!'),
            (12.0, 'Hello World 12!'),
    ):
        proc = Process(target=worker, args=(sleeptime, message))
        proc.start()
        procs[proc.pid] = proc
    exitcode = 0
    while procs:
        sleep(POLL_DURATION)
        for pid, proc in procs.copy().items():
            if proc.exitcode is not None:
                proc.join()
                if proc.exitcode:
                    exitcode = 1
                del procs[pid]
    sys.exit(exitcode)


if __name__ == '__main__':
    main()