manager.py

#!/usr/bin/env python3

import multiprocessing
import os
from multiprocessing.managers import BaseManager

PORT = 7481
KEY = b'AiZa5Uavcoh3PiajvaeTee5z'  # keep it secret, keep it safe !


class QueueManager(BaseManager):
    """This Manager holds a Queue and waits for clients to use it."""
    pass


class QueueClient:
    """Base class for users of the Queue."""
    def __init__(self):
        QueueManager.register('get_queue')
        manager = QueueManager(address=(os.environ.get('HOST', 'localhost'), PORT), authkey=KEY)
        manager.connect()
        self.queue = manager.get_queue()


if __name__ == '__main__':
    queue = multiprocessing.Queue()
    QueueManager.register('get_queue', callable=lambda: queue)
    QueueManager(address=('', PORT), authkey=KEY).get_server().serve_forever()