Собственный менеджер очередей. multiprocessing, queue и сорок строк кода

multiprocessing_workers.py

from multiprocessing.managers import BaseManager
from multiprocessing import Queue

ADDRESS = ('127.0.0.1', 5518)
AUTHKEY = 'foo'

def start_server():
    class Manager(BaseManager):
        pass
    queue = Queue()
    Manager.register('get_queue', lambda: queue)
    manager = Manager(address=ADDRESS, authkey=AUTHKEY)
    manager.get_server().serve_forever()

def start_worker():
    queue = get_client_queue()
    while True:
        func, args, kwargs = queue.get()
        print func(*args, **kwargs)

def enqueue(func, *args, **kwargs):
    queue = get_client_queue()
    queue.put((func, args, kwargs))

def get_client_queue():
    class Manager(BaseManager):
        pass
    Manager.register('get_queue')
    manager = Manager(address=ADDRESS, authkey=AUTHKEY)
    manager.connect()
    return manager.get_queue()

if __name__ == '__main__':
    from IPython import embed
    embed()