from multiprocessing import Process, Queue, Event
import time
import uuid
import os
 
 
NB_WORKERS = 3
NB_MAILS_PER_5_SECONDS = 2
MAIL_MANAGEMENT_DURATION_SECONDS = .2 # reduced so we do not timeout
 
class StopSentinel:
    pass
 
def list_new_mails_id():
    for i in range(NB_MAILS_PER_5_SECONDS):
        # fake mailbox msg list
        yield str(uuid.uuid1())
 
def mail_worker(msg_ids, event):
    pid = os.getpid()
    print(f"Starting worker PID = {pid} and queue={msg_ids} queue size={msg_ids.qsize()} ...")
    while True:
        if event.is_set():
            break # terminate
        # prevent lost messages by preventing the main
        print(f"[{pid}] Waiting a mail to manage...")
        msg_id = msg_ids.get()
        if isinstance(msg_id, StopSentinel):
            break
        print(f"[{pid}] managing mail msg_id = {msg_id} ...")
        # here should read mail msg_id and remove it from mailbox when finish
        print(f"[{pid}] --> fake duration of {MAIL_MANAGEMENT_DURATION_SECONDS}s")
        time.sleep(MAIL_MANAGEMENT_DURATION_SECONDS)
 
 
if __name__ == "__main__":
    msg_id_queue = Queue()
    events = [Event() for _ in range(NB_WORKERS)]
    processes = [Process(target=mail_worker, args=(msg_id_queue, events[i])) for i in range(NB_WORKERS)]
    for p in processes:
        p.start()
 
    for iteration_number in range(5): # so we eventually terminate
        for msg_id in list_new_mails_id():
            msg_id_queue.put(msg_id)
        print("\nWaiting for new mails to come...\n")
        time.sleep(.2) # Reduced so we do not timeout
        # Kill some processes from time to time
        if iteration_number == 1:
            # Kill the first process
            print('terminating process 0')
            events[0].set()
        elif iteration_number == 2:
            # Kill the first process
            print('terminating process 1')
            events[1].set()
 
    # Put enough stop sentinels in the queue (extras are okay)
    stop_sentinel = StopSentinel()
    for _ in range(NB_WORKERS):
        msg_id_queue.put(stop_sentinel)
    for p in processes:
        p.join()# your code goes here
    print('Done!')

ZnJvbSBtdWx0aXByb2Nlc3NpbmcgaW1wb3J0IFByb2Nlc3MsIFF1ZXVlLCBFdmVudAppbXBvcnQgdGltZQppbXBvcnQgdXVpZAppbXBvcnQgb3MKCgpOQl9XT1JLRVJTID0gMwpOQl9NQUlMU19QRVJfNV9TRUNPTkRTID0gMgpNQUlMX01BTkFHRU1FTlRfRFVSQVRJT05fU0VDT05EUyA9IC4yICMgcmVkdWNlZCBzbyB3ZSBkbyBub3QgdGltZW91dAoKY2xhc3MgU3RvcFNlbnRpbmVsOgogICAgcGFzcwoKZGVmIGxpc3RfbmV3X21haWxzX2lkKCk6CiAgICBmb3IgaSBpbiByYW5nZShOQl9NQUlMU19QRVJfNV9TRUNPTkRTKToKICAgICAgICAjIGZha2UgbWFpbGJveCBtc2cgbGlzdAogICAgICAgIHlpZWxkIHN0cih1dWlkLnV1aWQxKCkpCgpkZWYgbWFpbF93b3JrZXIobXNnX2lkcywgZXZlbnQpOgogICAgcGlkID0gb3MuZ2V0cGlkKCkKICAgIHByaW50KGYiU3RhcnRpbmcgd29ya2VyIFBJRCA9IHtwaWR9IGFuZCBxdWV1ZT17bXNnX2lkc30gcXVldWUgc2l6ZT17bXNnX2lkcy5xc2l6ZSgpfSAuLi4iKQogICAgd2hpbGUgVHJ1ZToKICAgICAgICBpZiBldmVudC5pc19zZXQoKToKICAgICAgICAgICAgYnJlYWsgIyB0ZXJtaW5hdGUKICAgICAgICAjIHByZXZlbnQgbG9zdCBtZXNzYWdlcyBieSBwcmV2ZW50aW5nIHRoZSBtYWluCiAgICAgICAgcHJpbnQoZiJbe3BpZH1dIFdhaXRpbmcgYSBtYWlsIHRvIG1hbmFnZS4uLiIpCiAgICAgICAgbXNnX2lkID0gbXNnX2lkcy5nZXQoKQogICAgICAgIGlmIGlzaW5zdGFuY2UobXNnX2lkLCBTdG9wU2VudGluZWwpOgogICAgICAgICAgICBicmVhawogICAgICAgIHByaW50KGYiW3twaWR9XSBtYW5hZ2luZyBtYWlsIG1zZ19pZCA9IHttc2dfaWR9IC4uLiIpCiAgICAgICAgIyBoZXJlIHNob3VsZCByZWFkIG1haWwgbXNnX2lkIGFuZCByZW1vdmUgaXQgZnJvbSBtYWlsYm94IHdoZW4gZmluaXNoCiAgICAgICAgcHJpbnQoZiJbe3BpZH1dIC0tPiBmYWtlIGR1cmF0aW9uIG9mIHtNQUlMX01BTkFHRU1FTlRfRFVSQVRJT05fU0VDT05EU31zIikKICAgICAgICB0aW1lLnNsZWVwKE1BSUxfTUFOQUdFTUVOVF9EVVJBVElPTl9TRUNPTkRTKQoKCmlmIF9fbmFtZV9fID09ICJfX21haW5fXyI6CiAgICBtc2dfaWRfcXVldWUgPSBRdWV1ZSgpCiAgICBldmVudHMgPSBbRXZlbnQoKSBmb3IgXyBpbiByYW5nZShOQl9XT1JLRVJTKV0KICAgIHByb2Nlc3NlcyA9IFtQcm9jZXNzKHRhcmdldD1tYWlsX3dvcmtlciwgYXJncz0obXNnX2lkX3F1ZXVlLCBldmVudHNbaV0pKSBmb3IgaSBpbiByYW5nZShOQl9XT1JLRVJTKV0KICAgIGZvciBwIGluIHByb2Nlc3NlczoKICAgICAgICBwLnN0YXJ0KCkKCiAgICBmb3IgaXRlcmF0aW9uX251bWJlciBpbiByYW5nZSg1KTogIyBzbyB3ZSBldmVudHVhbGx5IHRlcm1pbmF0ZQogICAgICAgIGZvciBtc2dfaWQgaW4gbGlzdF9uZXdfbWFpbHNfaWQoKToKICAgICAgICAgICAgbXNnX2lkX3F1ZXVlLnB1dChtc2dfaWQpCiAgICAgICAgcHJpbnQoIlxuV2FpdGluZyBmb3IgbmV3IG1haWxzIHRvIGNvbWUuLi5cbiIpCiAgICAgICAgdGltZS5zbGVlcCguMikgIyBSZWR1Y2VkIHNvIHdlIGRvIG5vdCB0aW1lb3V0CiAgICAgICAgIyBLaWxsIHNvbWUgcHJvY2Vzc2VzIGZyb20gdGltZSB0byB0aW1lCiAgICAgICAgaWYgaXRlcmF0aW9uX251bWJlciA9PSAxOgogICAgICAgICAgICAjIEtpbGwgdGhlIGZpcnN0IHByb2Nlc3MKICAgICAgICAgICAgcHJpbnQoJ3Rlcm1pbmF0aW5nIHByb2Nlc3MgMCcpCiAgICAgICAgICAgIGV2ZW50c1swXS5zZXQoKQogICAgICAgIGVsaWYgaXRlcmF0aW9uX251bWJlciA9PSAyOgogICAgICAgICAgICAjIEtpbGwgdGhlIGZpcnN0IHByb2Nlc3MKICAgICAgICAgICAgcHJpbnQoJ3Rlcm1pbmF0aW5nIHByb2Nlc3MgMScpCiAgICAgICAgICAgIGV2ZW50c1sxXS5zZXQoKQoKICAgICMgUHV0IGVub3VnaCBzdG9wIHNlbnRpbmVscyBpbiB0aGUgcXVldWUgKGV4dHJhcyBhcmUgb2theSkKICAgIHN0b3Bfc2VudGluZWwgPSBTdG9wU2VudGluZWwoKQogICAgZm9yIF8gaW4gcmFuZ2UoTkJfV09SS0VSUyk6CiAgICAgICAgbXNnX2lkX3F1ZXVlLnB1dChzdG9wX3NlbnRpbmVsKQogICAgZm9yIHAgaW4gcHJvY2Vzc2VzOgogICAgICAgIHAuam9pbigpIyB5b3VyIGNvZGUgZ29lcyBoZXJlCiAgICBwcmludCgnRG9uZSEnKQ==