python 分布式进程

import random, time, Queue
from multiprocessing.managers import BaseManager

task_queue = Queue.Queue()
result_queue = Queue.Queue()

class QueueManager(BaseManager):
pass

QueueManager.register('get_task_queue', callable=lambda:task_queue)
QueueManager.register('get_result_queue', callable=lambda:result_queue)
manager = QueueManager(address=('', 5000), authkey='abc')
manager.start()
task = manager.get_task_queue()
result = manager.get_result_queue()
for i in range(10000000):
print 'put task %d ..' % (i)
task.put(i)
for i in range(1000000):
r = result.get(timeout = 10)
print 'result: %s' % r
manager.shutdown()

import time, sys, Queue
from multiprocessing.managers import BaseManager

class QueueManager(BaseManager):
pass

QueueManager.register('get_task_queue')
QueueManager.register('get_result_queue')
server_addr = '10.16.77.94'
print 'Connect to server %s ..' % (server_addr)
m = QueueManager(address=(server_addr, 5000), authkey='abc')
m.connect()
task = m.get_task_queue()
result = m.get_result_queue()
while True:
try:
n = task.get(timeout=10)
print n
except Queue.Empty:
print 'task queue is empty'