multiprocessing_terminator.py

import multiprocessing
import time

class ChildThread(multiprocessing.Process):
    def __init__(self, stopper, counter, **kwargs):
        super().__init__(**kwargs)
        self.stopper = stopper
        self.counter = counter

    def run(self):

        time.sleep(self.counter)
        print('I am a child {}'.format(self.counter))


class ParentThread(multiprocessing.Process):
    def __init__(self, stopper, **kwargs):
        super().__init__(**kwargs)

        self.stopper = stopper

    def run(self):

        counter = 0
        while not self.stopper.is_set():
            counter += 1
            child_stopper = threading.Event()

            child = ChildThread(child_stopper, counter)
            child.start()
            exited  = child.join(timeout=5)

            if not exited:
                print("It won't DIEEEE {}".format(counter))
                child.terminate()

            print(child.exitcode, 'exitcode')

if __name__ == "__main__":

    import sys
    import time
    import threading

    stopper = threading.Event()
    parent = ParentThread(stopper)

    def signalHandler(signum, frame):
        stopper.set()
        parent.join()

    parent.start()