python multiprocessing example

Server Code:

#!/usr/bin/python
#-*- coding: UTF-8 -*-
# mpserver.py
#
# Queues are thread and process safe.

from multiprocessing.managers import BaseManager

# g as a server process state
g = 10000

class MathClass(object):
    def add(self, x, y):
        return x + y + g
    def mul(self, x, y):
        return x * y

class MathManager(BaseManager):
    pass

MathManager.register(‘Math‘, MathClass)

manager = MathManager(address=(‘‘, 50000), authkey=‘abc‘)
server = manager.get_server()
server.serve_forever()

Client Code:

#!/usr/bin/python
#-*- coding: UTF-8 -*-
# mpclient.py
#
# Queues are thread and process safe.

from multiprocessing.managers import BaseManager

class MathClass(object): pass    

class MathManager(BaseManager): pass

MathManager.register(‘Math‘, MathClass)

manager = MathManager(address=(‘‘, 50000), authkey=‘abc‘)
manager.connect()
m = manager.Math()

print m.add(100, 20)