stoppable_process.py

stoppable_process.py

from multiprocessing import Process, Queue
import queue
import time

class StoppableProcess(Process):
    def __init__(self, lol):
        super().__init__()
        self.lol = lol
        self.q = Queue()

    def run(self):
        print(self.lol)

        while True:
            time.sleep(1)
            print("hi")
            try:
                self.q.get(False)
                self.q.close()
                return
            except queue.Empty as _:
                pass

    def join(self):
        print("time to stop")
        self.q.put("stop")
        super().join()
        self.q.close()


if __name__ == "__main__":
    #time.sleep(5)
    a = LoggerProcess("a")
    a.start()
    time.sleep(5)
    print("oh well")
    a.join()
    time.sleep(5)
    print("done")