Problem with multiprocessing managers

Metalone jcb at iteris.com
Wed Jan 6 17:50:28 EST 2010


>From the documentation for Using a remote manager there is the
following example code:

from multiprocessing.managers import BaseManager
import Queue
queue = Queue.Queue()
class QueueManager(BaseManager): pass
QueueManager.register('get_queue', callable=lambda:queue)
m = QueueManager(address=('', 50000), authkey='abracadabra')
s = m.get_server()
s.serve_forever()

I don't know how to stop the server.
The documentation states that to call shutdown(), start() must be used
instead of server_forever().
If I use m.start() instead of m.get_server().server_forever() I
receive a PicklingError.



More information about the Python-list mailing list